2
My Flink 작업에는/lib 폴더에 저장할 수있는 클라이언트가 제공 한 jar 파일이 있습니다. 클러스터를 다시 시작하지 않고 업데이트 된 jar 파일을 다시로드하는 방법이 있습니까?Apache Flink : 작업을 다시 시작하지 않고 업데이트 된 jar 파일을 어떻게 다시로드 할 수 있습니까?
A
답변
0
아니요, 현재 버전에서는 사용할 수 없습니다 (Flink 1.4.0, Dec 2017).
Flink는 savepoints을 응용 프로그램의 상태로 저장합니다. 응용 프로그램의 코드 (또는 종속성)를 변경하려면 세이브 포인트를 가져 와서 코드/종속성을 업데이트하고 세이브 포인트에서 응용 프로그램을 다시 시작해야합니다.
이 기술은 응용 프로그램을 위 또는 아래로 확장하거나 마이그레이션하는 데에도 사용할 수 있습니다.
감사합니다. 향후 버전의 범위입니까? – wittyameta
나는이 방향으로의 노력을 알지 못한다. 지역 사회는 훨씬 빠른 세이브 포인트 및 복구 사이클을 위해 노력하고 있습니다. 작업이 일시적으로 중단 된 경우 (즉, 오류가 발생하지 않은 경우) 데이터를 로컬에 저장하고 프로세스를 재시작 할 수 있습니다. –