ich einen lokalen flink Cluster leite mitDoes Flink Cache Java-Klassen, wenn sie in Cluster ausgeführt wird (also nicht über eine IDE)
./bin/start_local.sh
ich flink Job starten, indem
./bin/flink run -p 3 lib/myApp.jar <insert command line args here>
Diese Arbeiten laufen wie erwartet. Wenn ich jedoch meine JAR-Datei (d. H. lib/myApp.jar) aktualisieren und den Job wie oben beschrieben neu starten sollte, scheint meine neue JAR-Datei nicht wirksam zu sein. In diesem speziellen Fall habe ich die Schemaausgabe von der JAR aktualisiert, indem ich ein Feld umbenannt habe. Die Ausgabe des Jobs enthielt immer noch das alte Feld, wenn der Job mithilfe der aktualisierten JAR neu gestartet wurde.
Gibt es einen Cache, der aktualisiert werden muss? Ist dies der richtige Weg, um eine Anwendung zu aktualisieren? Beachten Sie, dass für die Zwecke hier ist mir Sparpoints für jetzt nicht wichtig.
Danke!
Wenn Sie maven verwenden, haben Sie ein "mvn clean package" probiert? –
Ich benutze Gradle. Und ich habe zuerst sauber gemacht. Funktioniert immer noch nicht. – victtim