翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。 # 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: Long-Term Support for the Final Release of Apache Flink 1.x Line](https://cwiki.apache.org/confluence/display/FLINK/FLIP-458%3A+Long-Term+Support+for+the+Final+Release+of+Apache+Flink+1.x+Line)」を参照してください。 **注記** 過去にサポートされていたバージョンの Apache Flink を使用していて、既存のアプリケーションを Apache Flink 1.20.0 にアップグレードする場合は、インプレースの Apache Flink バージョンアップグレードを使用してアップグレードできます。詳細については、「[Apache Flink のインプレースバージョンアップグレードを使用する](how-in-place-version-upgrades.md)」を参照してください。インプレースのバージョンアップグレードでは、スナップショット、ログ、メトリクス、タグ、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: Add DISTRIBUTED BY clause](https://cwiki.apache.org/confluence/display/FLINK/FLIP-376%3A+Add+DISTRIBUTED+BY+clause) | | DataStream API: フルパーティション処理のサポート | Flink 1.20 では、キーなしストリームに対する集約処理を FullPartitionWindow API を介して組み込みでサポートしています。 | [FLIP-380: Support Full Partition Processing on Non-keyed DataStream](https://cwiki.apache.org/confluence/display/FLINK/FLIP-380%3A+Support+Full+Partition+Processing+On+Non-keyed+DataStream) | | Flink Dashboard でデータスキュースコアを表示する | Flink 1.20 ダッシュボードにデータスキュー情報が表示されるようになりました。Flink ジョブグラフ UI の各演算子には、追加のデータスキュースコアが表示されます。 | [FLIP-418: Show data skew score on Flink Dashboard](https://cwiki.apache.org/confluence/display/FLINK/FLIP-418%3A+Show+data+skew+score+on+Flink+Dashboard) | Apache Flink 1.20.0 リリースドキュメントについては、「[Apache Flink Documentation v1.20.0](https://nightlies.apache.org/flink/flink-docs-stable/)」を参照してください。Flink 1.20 リリースノートについては、「[Release notes - Flink 1.20](https://nightlies.apache.org/flink/flink-docs-release-1.20/release-notes/flink-1.20/)」を参照してください。 ## コンポーネント **Flink 1.20 コンポーネント** | コンポーネント | バージョン | | --- | --- | | Java | 11 (推奨) | | Python | 3.11 | | Kinesis Data Analytics Flink ランタイム (aws-kinesisanalytics-runtime) | 1.2.0 | | Connector | 使用可能なコネクタの詳細については、「[Apache Flink connectors](https://docs.aws.amazon.com/managed-flink/latest/java/how-flink-connectors.html)」を参照してください。 | | 「[Apache Beam （Beamアプリケーションのみ）](https://aws.amazon.com/developer/language/python/)」 | Flink 1.20 と互換性のある Apache Flink Runner はありません。詳細については、「[Flink Version Compatibility](https://beam.apache.org/documentation/runners/flink/#flink-version-compatibility)」を参照してください。 | ## 既知の問題 **Apache ビーム** 現在、Apache Beam には Flink 1.20 と互換性のある Apache Flink Runner はありません。詳細については、「[Flink Version Compatibility](https://beam.apache.org/documentation/runners/flink/#flink-version-compatibility)」を参照してください。 **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 を引き続き使用できます。詳細については、「[Creating a Studio notebook](https://docs.aws.amazon.com/managed-flink/latest/java/how-zeppelin-creating.html)」を参照してください。 **バックポートされたバグ修正** Amazon Managed Service for Apache Flink のバックポートは、Flink コミュニティからの重大な問題を修正します。以下は、バックポートしたバグ修正のリストです。 **バックポートされたバグ修正** | Apache Flink JIRA リンク | 説明 | | --- | --- | | [FLINK-35886](https://issues.apache.org/jira/browse/FLINK-35886) | この修正は、サブタスクがバックプレッシャー/ブロックされたときに、ウォーターマークのアイドルタイムアウトが誤って計上される問題に対処します。 |