Amazon Managed Service for Apache Flink 1.20 - Managed Service for Apache Flink
지원 기능 Components알려진 문제

Amazon Managed Service for Apache Flink(Amazon MSF)는 이전에 Amazon Kinesis Data Analytics for Apache Flink로 알려져 있었습니다.

Amazon Managed Service for Apache Flink 1.20

Managed Service for Apache Flink은 이제 Apache Flink 버전 1.20.0을 지원합니다. 이 섹션에서는 Managed Service for Apache Flink의 Apache Flink 1.20.0을 지원하면서 도입된 새로운 주요 기능과 변경 사항을 소개합니다. Apache Flink 1.20은 마지막 1.x 릴리스이자 Flink 장기 지원(LTS) 버전이 될 것으로 예상됩니다. 자세한 내용은 FLIP-458: Apache Flink 1.x 라인의 최종 릴리스 장기 지원을 참조하세요.

참고

지원되는 이전 Apache Flink 버전을 사용 중이며 기존 애플리케이션을 Apache Flink 1.20.0으로 업그레이드하려는 경우, 인플레이스 Apache Flink 버전 업그레이드를 사용하여 업그레이드할 수 있습니다. 자세한 내용은 Apache Flink에 인플레이스 버전 업그레이드 사용 섹션을 참조하세요. 인플레이스 버전 업그레이드를 사용하면 스냅샷, 로그, 지표, 태그, Flink 구성 등을 포함하여 Apache Flink 버전 전반에 걸쳐 단일 ARN을 기준으로 애플리케이션 추적성을 유지할 수 있습니다.

Apache Flink 1.20.0에서는 SQL API, DataStream API, Flink 대시보드가 개선되었습니다.

지원되는 기능 및 관련 설명서
지원 기능 설명 Apache Flink 설명서 참조
DISTRIBUTED BY 절 추가 여러 SQL 엔진이 Partitioning, Bucketing 또는Clustering의 개념을 공개합니다. Flink 1.20은 Flink에 Bucketing 개념을 도입합니다. FLIP-376: DISTRIBUTED BY 절 추가
DataStream API: 전체 파티션 처리 지원 Flink 1.20은 FullPartitionWindow API를 통해 키가 지정되지 않은 스트림의 집계를 기본 지원합니다. FLIP-380: 키가 지정되지 않은 DataStream에서 전체 파티션 처리 지원
Flink 대시보드에 데이터 스큐 점수 표시 Flink 1.20 대시보드는 데이터 스큐 정보를 표시합니다. Flink 작업 그래프 UI의 각 연산자는 추가 데이터 스큐 점수를 표시합니다. FLIP-418: Flink 대시보드에 데이터 스큐 점수 표시

Apache Flink 1.20.0 릴리스 설명서는 Apache Flink 설명서 v1.20.0을 참조하세요. Flink 1.20 릴리스 정보는 릴리스 노트 - Flink 1.20을 참조하세요.

Flink 1.20 구성 요소
구성 요소 버전
Java 11 (권장)
Python

3.11
Kinesis Data Analytics Flink Runtime(aws-kinesisanalytics-runtime) 1.2.0
Connectors 사용 가능한 커넥터에 관한 자세한 내용은 Apache Flink 커넥터를 참조하세요.
Apache Beam (빔 애플리케이션만 해당)

Flink 1.20에는 호환되는 Apache Flink 러너가 없습니다. 자세한 내용은 Flink 버전 호환성을 참조하세요.

Apache Beam

현재 Apache Beam에는 Flink 1.20과 호환되는 Apache Flink 러너가 없습니다. 자세한 내용은 Flink 버전 호환성을 참조하세요.

Amazon Managed Service for Apache Flink Studio

Amazon Managed Service for Apache Flink Studio는 Apache Zeppelin 노트북을 사용해 Apache Flink 스트림 처리 애플리케이션을 개발하고 코드를 디버깅하고 실행하기 위한 단일 인터페이스 개발 환경을 제공합니다. Flink 1.20 지원을 위해서는 Zeppelin의 Flink 인터프리터를 업그레이드해야 합니다. 이 작업은 Zeppelin 커뮤니티와 함께 진행될 예정입니다. 작업이 완료되면 이러한 참고 사항을 업데이트할 예정입니다. Amazon Managed Service for Apache Flink Studio에서는 Flink 1.15를 계속 사용할 수 있습니다. 자세한 내용은 Studio 노트북 생성을 참조하세요.

백포트된 버그 수정

Amazon Managed Service for Apache Flink는 주요 문제를 해결하기 위해 Flink 커뮤니티에서 제공하는 버그 수정 사항을 백포트하고 있습니다. 다음은 백포트된 버그 수정 목록입니다.

백포트된 버그 수정
Apache Flink JIRA 링크 설명
FLINK-35886 이 수정 사항은 하위 작업이 역압/차단된 경우 워터마크 유휴 제한 시간이 잘못 계산되는 문제를 해결합니다.