Flink Native 모드의 제어 흐름

Flink Native 모드의 제어 흐름 An architecture diagram generated by Archify. 운영자 · kubectl apply · Architecture component 운영자 kubectl apply Kubernetes API Server · kube-apiserver · EKS 클러스터 Kubernetes API Server kube-apiserver Flink Kubernetes Operator · CR 감시 · 조정 루프 · EKS 클러스터 Flink Kubernetes Operator CR 감시 · 조정 루프 JobManager Pod · ResourceManager 내장 · EKS 클러스터 › Flink 클러스터 (FlinkDeployment) JobManager Pod ResourceManager 내장 TaskManager Pod 1 · 태스크 슬롯 · 서브태스크 실행 · EKS 클러스터 › Flink 클러스터 (FlinkDeployment) TaskManager Pod 1 태스크 슬롯 · 서브태스크 실행 TaskManager Pod 2 · 태스크 슬롯 · 서브태스크 실행 · EKS 클러스터 › Flink 클러스터 (FlinkDeployment) TaskManager Pod 2 태스크 슬롯 · 서브태스크 실행 FlinkDeployment / FlinkSessionJob CR 적용 CR 변경 감시 생성 / 조정 ResourceManager: TaskManager Pod 요청 · 반납 서브태스크 · 체크포인트 서브태스크 · 체크포인트 EKS 클러스터 Flink 클러스터 (FlinkDeployment)

Flink Kubernetes Operator

  • • Native와 Standalone 모두 지원
  • • Cluster/job lifecycle과 upgrade 조건 관리

JobManager

  • • Graph 생성 위치는 제출 모드에 따름
  • • Native ResourceManager는 Kubernetes API 사용

TaskManager

  • • Slot sharing과 operator chaining
  • • Pod 용량과 node capacity는 별도 계층