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

Amazon Managed Service for Apache Flink は、以前は 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全体で 1 つの に対してアプリケーションのトレーサビリティを維持します。

Apache Flink 1.20.0 ではAPIs、SQL、 DataStreamAPIs、および Flink ダッシュボードの改善が導入されています。

サポートされている機能と関連ドキュメント
サポートされている機能 説明 Apache Flink ドキュメントリファレンス
DISTRIBUTED BY 句を追加する 多くのSQLエンジンは、Partitioning、、Bucketingまたは の概念を公開しますClustering。Flink 1.20 は、 の概念Bucketingを Flink に導入します。 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 コンポーネント
コンポーネント Version
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 Interpreter のアップグレードが必要です。この作業は Zeppelin コミュニティでスケジュールされています。作業が完了したら、これらのメモを更新します。Amazon Managed Service for Apache Flink Studio では、引き続き Flink 1.15 を使用できます。詳細については、「Studio ノートブックの作成」を参照してください。

バックポートされたバグ修正

Amazon Managed Service for Apache Flink バックポートは、重大な問題に対する Flink コミュニティからの修正を行います。以下は、バックポートしたバグ修正のリストです。

バックポートされたバグ修正
Apache Flink JIRA リンク 説明
FLINK-35886 この修正は、サブタスクがバックプレッシャー/ブロックされた場合にウォーターマークアイドルタイムアウトを誤って処理する問題に対処します。