Apache Beam을 사용하여 Managed Service for Apache Flink 애플리케이션 생성 - Managed Service for Apache Flink

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

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

Apache Beam을 사용하여 Managed Service for Apache Flink 애플리케이션 생성

참고

아파치 플링크 버전 1.19에서는 아파치 빔이 지원되지 않습니다. 2024년 6월 27일 현재, 플링크 1.18과 호환되는 아파치 플링크 러너는 없습니다. 자세한 내용은 Apache Beam 설명서의 Flink 버전 호환성을 참조하십시오. >

Apache Beam 프레임워크를 Managed Service for Apache Flink 애플리케이션과 함께 사용하여 스트리밍 데이터를 처리할 수 있습니다. Apache Beam을 사용하는 Managed Service for Apache Flink 애플리케이션은 Apache Flink 러너를 사용하여 Beam 파이프라인을 실행합니다.

Managed Service for Apache Flink 애플리케이션에서 Apache Beam을 사용하는 방법에 대한 자습서는 아파치 플링크용 매니지드 서비스와 CloudFormation 함께 사용 섹션을 참조하세요.

Managed Service for Apache Flink와 함께 Apache Beam 사용

Managed Service for Apache Flink와 함께 Apache Flink 러너를 사용하는 방법에 대해서는 다음을 참고하세요.

  • Apache Beam 지표는 Managed Service for Apache Flink 콘솔에서 볼 수 없습니다.

  • Apache Beam은 Apache Flink 버전 1.8 이상을 사용하는 Managed Service for Apache Flink 애플리케이션에서만 지원됩니다. Apache Beam은 Apache Flink 버전 1.6을 사용하는 Managed Service for Apache Flink 애플리케이션에서 지원되지 않습니다.

빔 기능

Managed Service for Apache Flink는 Apache Flink 러너와 동일한 Apache Beam 기능을 지원합니다. Apache Flink 러너에서 지원되는 기능에 대한 자세한 내용을 알아보려면 Beam 병립성 매트릭스를 참조하세요.

Managed Service for Apache Flink 서비스에서 Apache Flink 애플리케이션을 테스트하여 애플리케이션에 필요한 모든 기능을 지원하는지 확인하는 것이 좋습니다.