Amazon Managed Service for Apache Flink 1.20 - Managed Service for Apache Flink
サポートされている機能 コンポーネント既知の問題

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 をサポートするようになりました。このセクションでは、Apache Flink 1.20.0 の Managed Service for Apache Flink サポートで導入された主な新機能と変更点について説明します。Apache Flink 1.20 は、最後の 1.x リリースと Flink 長期サポート (LTS) バージョンになる予定です。詳細については、FLIP-458: Apache Flink 1.x Line の最終リリースの長期サポート」を参照してください。

注記

以前にサポートされているバージョンの Apache Flink を使用していて、既存のアプリケーションを Apache Flink 1.20.0 にアップグレードする場合は、インプレース Apache Flink バージョンアップグレードを使用してアップグレードできます。詳細については、「Apache Flink のインプレースバージョンアップグレードを使用する」を参照してください。インプレースバージョンアップグレードでは、スナップショット、ログ、メトリクス、タグ、Flink 設定など、Apache Flink バージョン全体で単一の ARN に対するアプリケーションのトレーサビリティを維持します。

Apache Flink 1.20.0 では、SQL APIsDataStream APIs、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 Dashboard でデータスキュースコアを表示する Flink 1.20 ダッシュボードにデータスキュー違反が表示されるようになりました。Flink ジョブグラフ UI の各演算子には、追加のデータスキュースコアが表示されます。 FLIP-418: Flink Dashboard にデータスキュースコアを表示する

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
Connector 使用可能なコネクタの詳細については、「Apache Flink コネクタ」を参照してください。
「Apache Beam （Beamアプリケーションのみ）」

Flink 1.20 用の互換性のある Apache Flink Runner はありません。詳細については、「Flink バージョンの互換性」を参照してください。

Apache ビーム

現在、Apache Beam には Flink 1.20 用の互換性のある Apache Flink Runner はありません。詳細については、「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 この修正は、サブタスクがバックプレッシャー/ブロックされたときにウォーターマークアイドルタイムアウトが誤って計算される問題に対処します。