기계 번역으로 제공되는 번역입니다. 제공된 번역과 원본 영어의 내용이 상충하는 경우에는 영어 버전이 우선합니다.
Amazon Managed Service for Apache Flink 2.3
Managed Service for Apache Flink는 이제 Apache Flink 버전 2.3.0을 지원합니다. 이 섹션에서는 Apache Flink 2.3.0의 Managed Service for Apache Flink 지원과 함께 도입된 주요 새로운 기능과 변경 사항을 소개합니다.
참고
이전에 지원되는 버전의 Apache Flink를 사용 중이고 기존 애플리케이션을 Apache Flink 2.3.0으로 업그레이드하려는 경우 인플레이스 Apache Flink 버전 업그레이드를 사용하여 업그레이드할 수 있습니다. 자세한 내용은 Apache Flink에 인플레이스 버전 업그레이드 사용 단원을 참조하십시오. 인플레이스 버전 업그레이드를 사용하면 스냅샷, 로그, 지표, 태그, Flink 구성 등을 포함하여 Apache Flink 버전 전반에 걸쳐 단일 ARN을 기준으로 애플리케이션 추적성을 유지할 수 있습니다.
참고
Flink 1.x에서 Flink 2.3으로 업그레이드하는 것은 주요 버전 업그레이드로, 주요 변경 사항 및 상태 호환성 고려 사항이 포함되어 있습니다. 1.x에서 업그레이드하기 전에 주요 변경 사항 및 사용 중단 및를 검토합니다Flink 2.2 업그레이드를 위한 상태 호환성 가이드.
지원되는 기능
Apache Flink 2.3.0에서는 SQL API, 왜곡된 워크로드에 대한 적응형 파티션 선택 및 Flink 대시보드가 개선되었습니다.
지원되는 기능 |
설명 |
Apache Flink 설명서 참조 |
|---|---|---|
SinkUpsertMaterializer 및 changelog 장애 개선 |
업서트 싱크에 CDC 또는 변경 로그 스트림을 작성할 때 업데이트 순서를 개선합니다. |
|
Application Management 읽기 APIs |
애플리케이션 수준 관찰성을 위한 새로운 읽기 전용 엔드포인트입니다. Amazon Managed Service for Apache Flink에서는 쓰기 엔드포인트가 비활성화됩니다. |
|
StreamPartitioner에 대한 적응형 파티션 선택 |
왜곡된 파티셔너 |
참고
지원 사례
옵트인 기능 |
설명 |
Apache Flink 설명서 참조 |
|---|---|---|
복구 중 체크포인트 지원 |
이는 오픈 소스의 실험적 기능이므로 기본적으로 비활성화됩니다. 지원 사례를 사용하여 애플리케이션에 대해 활성화하도록에 요청할 수 있습니다. |
Apache Flink 2.3.0 릴리스 설명서는 Apache Flink 설명서 v2.3.0
Apache Flink 2.3을 사용한 Amazon Managed Service for Apache Flink의 변경 사항
워터마크 정렬 기본값 보존
Apache Flink 2.3은 워터마크 정렬의 기본 동작을 변경하여 백로깅된 작업이 모든 다운스트림 리소스를 소비하지 못하도록 합니다. Amazon Managed Service for Apache Flink에서의 기본값pipeline.watermark-alignment.max-drift은 이전에 지원되는 Apache Flink 버전과의 이전 버전과의 호환성을 유지하고 업그레이드 시 동작 회귀로부터 기존 애플리케이션을 보호하기 0 위해 로 설정됩니다. 새로운 공정성 동작을 원하는 경우 애플리케이션 코드에서 pipeline.watermark-alignment.max-drift 프로그래밍 방식으로를 설정하여 옵트인할 수 있습니다. 자세한 내용은 FLINK-37399: 워터마크 정렬은 백로깅된 작업이 모든 리소스를 사용하는 것을 방지합니다를
구성 요소
구성 요소 |
버전 |
|---|---|
Java |
17(권장) |
Python |
3.12 |
Kinesis Data Analytics Flink Runtime(aws-kinesisanalytics-runtime) |
1.2.0 |
커넥터 |
사용 가능한 커넥터에 관한 자세한 내용은 Apache Flink 커넥터를 참조하세요. |
지원되지 않는 실험 기능
Amazon Managed Service for Apache Flink에서는 다음 Apache Flink 2.3 기능이 지원되지 않습니다.
구체화된 테이블: 지속적으로 유지 관리되고 쿼리 가능한 테이블 스냅샷.
사용자 지정 원격 측정 변경: 사용자 지정 지표 리포터 및 원격 측정 구성.
-
Flink 네이티브 S3 FileSystem(FLIP-555): 네이티브 S3 파일 시스템 구현(오픈 소스에서 실험적)
-
ForSt 상태 백엔드: 분해된 상태 스토리지(오픈 소스의 실험적 스토리지).
-
Java 21: Managed Service for Apache Flink에서 지원되지 않는 오픈 소스에서의 실험 지원.
Amazon Managed Service for Apache Flink Studio
Amazon Managed Service for Apache Flink의 Flink 2.3은 Studio 애플리케이션을 지원하지 않습니다. 자세한 내용은 Studio 노트북 생성을 참조하세요.
