Managed Service for Apache Flink 애플리케이션 실행 - Managed Service for Apache Flink
애플리케이션 및 작업 상태 식별배치 워크로드 실행

Amazon Managed Service for Apache Flink는 이전에 Amazon Kinesis Data Analytics for Apache Flink로 알려졌습니다.

기계 번역으로 제공되는 번역입니다. 제공된 번역과 원본 영어의 내용이 상충하는 경우에는 영어 버전이 우선합니다.

Managed Service for Apache Flink 애플리케이션 실행

이 주제에는 Managed Service for Apache Flink 실행에 대한 자세한 내용이 포함되어 있습니다.

Managed Service for Apache Flink 애플리케이션을 실행하면 서비스가 Apache Flink 작업을 생성합니다. Apache Flink 작업은 Managed Service for Apache Flink 애플리케이션의 실행 라이프사이클입니다. 작업 실행 및 작업에 사용되는 리소스는 Job Manager에서 관리합니다. Job Manager는 애플리케이션 실행을 작업으로 구분합니다. 각 작업은 작업 관리자가 관리합니다. 애플리케이션 성능을 모니터링할 때 각 Task Manager 또는 Job Manager 전체의 성능을 검사할 수 있습니다.

Apache Flink 작업에 대한 자세한 내용은 Apache Flink 설명서의 작업 및 예약을 참조하세요.

애플리케이션 및 작업 상태 식별

애플리케이션과 애플리케이션 작업 모두 현재 실행 상태입니다.

  • 애플리케이션 상태: 애플리케이션에는 실행 단계를 설명하는 현재 상태가 있습니다. 애플리케이션 상태에는 다음이 포함됩니다.

    • 꾸준한 애플리케이션 상태: 상태가 변경될 때까지 애플리케이션은 일반적으로 다음과 같은 상태를 유지합니다.

      • 준비: 새 애플리케이션이나 중지된 애플리케이션은 실행할 때까지 준비 상태입니다.

      • 가동: 성공적으로 시작된 애플리케이션은 가동 상태입니다.

    • 임시 애플리케이션 상태: 이러한 상태의 애플리케이션은 일반적으로 다른 상태로 전환되는 중입니다. 애플리케이션이 일정 시간 동안 임시 상태에 있는 경우 Force 파라미터가 true로 설정된 StopApplication 작업을 사용하여 애플리케이션을 중지할 수 있습니다. 이러한 상태에는 다음이 포함됩니다.

      • StartApplication 작업 후에 STARTING:이 발생합니다. 애플리케이션이 READY 상태에서 RUNNING 상태로 전환되고 있습니다.

      • StopApplication 작업 후에 STOPPING:이 발생합니다. 애플리케이션이 RUNNING 상태에서 READY 상태로 전환되고 있습니다.

      • DeleteApplication 작업 이후에 DELETING:이 발생합니다. 애플리케이션을 삭제하는 중입니다.

      • UpdateApplication 작업 후에 UPDATING:이 발생합니다. 애플리케이션이 업데이트 중이며 RUNNING 또는 READY 상태로 다시 전환됩니다.

      • AUTOSCALING: 애플리케이션은 ParallelismConfiguration의 AutoScalingEnabled 속성을 true으로 설정하고, 서비스는 애플리케이션의 병렬성을 높이고 있습니다. 애플리케이션이 이 상태인 경우 사용할 수 있는 유효한 API 작업은 Force 파라미터가 true로 설정된 StopApplication 작업뿐입니다. 자동 조정에 대한 자세한 내용을 알아보려면 Managed Service for Apache Flink에서 자동 조정 사용 섹션을 참조하세요.

      • FORCE_STOPPING:Force 파라미터가 true로 설정된 상태에서 StopApplication 작업을 호출한 후에 이 발생합니다. 애플리케이션을 강제 중지하는 중입니다. 애플리케이션이 STARTING, UPDATING, STOPPING 또는 AUTOSCALING 상태에서 READY 상태로 전환됩니다.

      • RollbackApplication 작업이 호출된 후에 ROLLING_BACK:이 발생합니다. 애플리케이션이 이전 버전으로 회귀하는 중입니다. 애플리케이션이 UPDATING 또는 AUTOSCALING 상태에서 RUNNING 상태로 전환됩니다.

      • Managed Service for Apache Flink가 애플리케이션에 패치를 적용하는 동안 MAINTENANCE:이 발생합니다. 자세한 내용을 알아보려면 Managed Service for Apache Flink의 유지 관리 작업 관리 섹션을 참조하세요.

    콘솔을 사용하거나 DescribeApplication 작업을 사용하여 애플리케이션 상태를 확인할 수 있습니다.

  • 작업 현황: 애플리케이션이 RUNNING 상태에 있으면 작업에는 현재 실행 단계를 설명하는 상태가 있습니다. 작업은 CREATED 상태에서 시작하고, 시작되면 RUNNING 상태로 진행됩니다. 오류 상황이 발생하는 경우 애플리케이션은 다음 상태가 됩니다.

    • Apache Flink 1.11 이상을 사용하는 애플리케이션의 경우 애플리케이션은 RESTARTING 상태가 됩니다.

    • Apache Flink 1.8 및 이전 버전을 사용하는 애플리케이션의 경우 플리케이션은 FAILING 상태가 됩니다.

    그러면 작업이 다시 시작될 수 있는지 여부에 따라 애플리케이션이 RESTARTING 또는 FAILED 상태로 진행됩니다.

    애플리케이션의 CloudWatch 로그에서 상태 변경을 검사하여 작업 상태를 확인할 수 있습니다.

배치 워크로드 실행

Managed Service for Apache Flink는 Apache Flink 배치 워크로드 실행을 지원합니다. 배치 작업에서 Apache Flink 작업이 FINISHED 상태가 되면 Managed Service for Apache Flink 애플리케이션 상태가 준비로 설정됩니다. Flink 작업 상태에 대한 자세한 내용을 알아보려면 작업 및 예약을 참조하십시오.