플 링크 다이내믹 스케일링

Question

현재 플 링크에서 확장 성을 연구 중입니다. 버전 1.2.0부터 동적 재조정이 도입되었습니다. 카프카 소스에서 데이터를 읽는 장기 실행 작업을 조정하는 방법을 모색 중입니다.

동적 재조정에 관한 질문.

1. 예를 들어, 내 FLINK 응용 프로그램을 확장하려면 새 작업 관리자를 추가, 나는 새로 추가 된 리소스를 사용하는 작업/실 세션을 다시 시작해야합니다?
2. 새로운 작업 관리자를 배치하고 작업 관리자와 대화하게 만들려면 실 클라이언트를 쓰는 것이 가능하다고 생각합니다. 기존 플 랭킹 원사 클라이언트 응용 프로그램에서 이미 사용 가능합니까?

이 질문이 너무 기본적인 경우, 나는 문서를 검토했지만 최근에 원사에 일부 테스트 배치와 함께 개념을 모두 집어 넣을 수 없었다는 것을 인정해야합니다.

Answer 1

현재 동적 확장은 키 상태 또는 키가 아닌 상태에 대해 연산자의 병렬 처리 (Flink 1.2)를 업데이트하는 기능을 의미합니다.

1. 예를 들어, 내 FLINK 응용 프로그램을 확장하려면 새 작업 관리자를 추가, 나는 새로 추가 된 리소스를 사용하는 작업/실 세션을 다시 시작해야합니다? - 예 작업을 먼저 중지하고 병렬 처리를 업데이트 한 다음 다시 시작해야합니다. 상태에 대해 걱정할 필요가 없습니다. 다시 파티션을 포함하여 Flink에서 처리 할 것입니다.

2. 새로운 작업 관리자를 배치하고 작업 관리자와 대화하게 만들려면 실 클라이언트를 쓰는 것이 가능하다고 생각하십니까? 이미 기존 플 랭킹 원사 클라이언트 응용 프로그램에서 사용할 수 있습니까? - 아니요 아니요. 이 기능은 앞으로 추가 될 것으로 보입니다. 현재, 우리는 그렇게 할 수 없습니다.