합니까 FLINK 캐시 자바 클래스</p> <pre><code>./bin/flink run -p 3 lib/myApp.jar <insert command line args here> </code></pre> <p>이 작업을 실행하여

Question

내가

./bin/start_local.sh 

가 나는 FLINK 작업을 시작 사용하여 로컬 FLINK 클러스터를 실행하고 (아닌 IDE를 통해 예) 클러스터에서 실행할 때 예상대로 그러나 JAR 파일 (예 : lib/myApp.jar)을 업데이트하고 위와 같이 작업을 다시 시작하면 새 JAR이 적용되지 않습니다. 이 특별한 경우에는 필드의 이름을 변경하여 JAR에서 스키마 출력을 업데이트했습니다. 갱신 된 JAR을 사용하여 작업을 다시 시작할 때 작업의 출력에는 여전히 이전 필드가있었습니다.

업데이트해야 할 캐시가 있습니까? 이 방법이 응용 프로그램을 업데이트하는 올바른 방법입니까? 여기서는 Savepoint에 대해서는 신경 쓰지 않습니다.

감사합니다.

Answer 1

WebUI가 여전히 이전 jar 파일을 사용하고 있기 때문에 이러한 현상이 발생합니다. 유 아티팩트를 생성 할 때

것은 당신이 다음 옵션을

를 다시 선택해야합니다, 전송 :

옵션 # 1 당신이 IDE에서 jar 파일을 재생 한 후 두 가지 방법이 있습니다 jar 파일을 다시 터미널을 통해 사용하는 명령을 사용합니다.

./bin/flink run -p 3 lib/myApp.jar <insert command line args here>

옵션 # 2 :는 사용할 옵션을 사용하여 항아리를 제출하면 conf.yaml 파일 다음

jobmanager.web.submit.enable: true 

에서 사용 가능이 옵션이 있는지 확인 web UI

를 사용하여 jar 파일을 제출 UI

추가 문제가 있으면 알려주십시오.