Flink Operator와 Native 모드 scaling

Flink Operator와 Native 모드 scaling An architecture diagram generated by Archify. FlinkDeployment CR · Application / Session cluster · Architecture component FlinkDeployment CR Application / Session cluster FlinkSessionJob CR · Session 클러스터에 제출하는 잡 · Architecture component FlinkSessionJob CR Session 클러스터에 제출하는 잡 Flink Kubernetes Operator · CR 조정 + 내장 오토스케일러 호스팅 · Architecture component Flink Kubernetes Operator CR 조정 + 내장 오토스케일러 호스팅 JobManager Pod · 잡 그래프 조정 · Architecture component JobManager Pod 잡 그래프 조정 TaskManager Pods · vertex 병렬 인스턴스 실행 · Architecture component TaskManager Pods vertex 병렬 인스턴스 실행 오토스케일러 · vertex별 병렬도 계산 · Architecture component 오토스케일러 vertex별 병렬도 계산 Flink REST metrics · Rates · backlog · pressure · Architecture component Flink REST metrics Rates · backlog · pressure 감시 감시 In-place / redeploy Native allocation / tasks 지표 생성 지표 생성 읽음 Enabled + constraints

평가 입력

  • • 처리율·edge ratio·backlog 목표
  • • Memory/GC pressure·quota·scaling 제약

Scaling 적용

  • • 관찰 모드에서 추천부터 확인
  • • State 복구·in-place/재배포 경로 검증