

翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。

# Apache Flink の設定
<a name="reference-flink-settings.title"></a>

Apache Flink 用 Managed Service は、Apache Flink フレームワークの実装です。Apache Flink 用 Managed Service は、このセクションで説明されているデフォルト値を使用します。これらの値には、Managed Service for Apache Flink アプリケーションのコード内で設定できるものもありますが、変更できないものもあります。

このセクションのリンクを使用して、Apache flink 設定と変更可能な設定の詳細を確認します。

**Topics**
+ [Apache Spark の設定](#apache-flink-configuration)
+ [ステートバックエンド](#reference-defaults-state-backend)
+ [Checkpointing](#reference-defaults-checkpoint)
+ [セーブポインティング](#reference-defaults-savepoint)
+ [ヒープサイズ](#reference-defaults-heap)
+ [バッファデブローティング](#reference-defaults-buffer-debloating)
+ [変更可能な Flink 設定プロパティ](reference-modifiable-settings.md)
+ [プログラムによる Flink 設定プロパティ](programmatic-configuration.md)
+ [設定済み Flink プロパティを表示する](viewing-modifiable-settings.md)

## Apache Spark の設定
<a name="apache-flink-configuration"></a>

Apache Flink 用 Managed Service には、ほとんどのプロパティに Apache Flink 推奨値と、一般的なアプリケーションプロファイルに基づくいくつかの値で構成されるデフォルトの Flink 設定が用意されています。Flink 設定の詳細については、「[設定](https://nightlies.apache.org/flink/flink-docs-master/docs/deployment/config/)」を参照してください。サービス提供のデフォルト設定は、ほとんどのアプリケーションに適用されます。ただし、並列度が高く、メモリやステートの使用量が多い特定のアプリケーションのパフォーマンスを向上させるために Flink の設定プロパティを微調整したり、Apache Flink の新しいデバッグ機能を有効にしたりする場合は、サポートケースをリクエストすることで特定のプロパティを変更することができます。詳細については、「[AWS サポートセンター](https://console.aws.amazon.com/support/home#/)」を参照してください。アプリケーションの現在の設定は、[Apache Flink ダッシュボード](https://docs.aws.amazon.com/managed-flink/latest/java/how-dashboard.html)を使用して確認できます。

## ステートバックエンド
<a name="reference-defaults-state-backend"></a>

Apache Flink 用 Managed Service は、一時的なデータをステートバックエンドに保存します。Apache Flink 用 Managed Service は、「**RocksDBStateBackend**」を使用しています。「`setStateBackend`」を呼び出して別のバックエンドを設定しても効果はありません。

ステートバックエンドでは、以下の機能が利用できます。
+ インクリメンタルステートのバックエンドスナップショット
+ 非同期ステートのバックエンドスナップショット
+ チェックポイントのローカルリカバリ

ステートバックエンドについて詳しくは、「Apache Flink ドキュメント」の「[State Backends](https://nightlies.apache.org/flink/flink-docs-release-1.19/ops/state/state_backends.html)」を参照してください。

## Checkpointing
<a name="reference-defaults-checkpoint"></a>

Apache Flink 用 Managed Service は、以下の値を持つデフォルトのチェックポイント設定を使用します。これらの値の一部は、[CheckpointConfiguration](https://docs.aws.amazon.com/managed-flink/latest/apiv2/API_CheckpointConfiguration.html) を使用して変更できます。変更したチェックポイント値を使用するには、Managed Service for Apache Flink の `CheckpointConfiguration.ConfigurationType` を `CUSTOM` に設定する必要があります。


****  

| 設定 | 変更することはできますか？ | その方法は? | デフォルト値 | 
| --- | --- | --- | --- | 
| CheckpointingEnabled | 変更可能 | [アプリケーションの作成](https://docs.aws.amazon.com/managed-flink/latest/apiv2/API_CreateApplication.html) [アプリケーションの更新](https://docs.aws.amazon.com/managed-flink/latest/apiv2/API_UpdateApplication.html) [CloudFormation](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/AWS_KinesisAnalyticsV2.html)  | 正 | 
| CheckpointInterval | 変更可能 | [アプリケーションの作成](https://docs.aws.amazon.com/managed-flink/latest/apiv2/API_CreateApplication.html) [アプリケーションの更新](https://docs.aws.amazon.com/managed-flink/latest/apiv2/API_UpdateApplication.html) [CloudFormation](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/AWS_KinesisAnalyticsV2.html)  | 60000 | 
| MinPauseBetweenCheckpoints | 変更可能 | [アプリケーションの作成](https://docs.aws.amazon.com/managed-flink/latest/apiv2/API_CreateApplication.html) [アプリケーションの更新](https://docs.aws.amazon.com/managed-flink/latest/apiv2/API_UpdateApplication.html) [CloudFormation](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/AWS_KinesisAnalyticsV2.html)  | 5000 | 
| アライメントされていないチェックポイント | 変更可能 | [サポートケース](https://console.aws.amazon.com/support/home#/) | 誤 | 
| 同時チェックポイントの数 | 変更不可 | 該当なし | 1 | 
| チェックポイントモード | 変更不可 | 該当なし | 1 回だけ | 
| チェックポイント保持ポリシー | 変更不可 | 該当なし | 故障した時 | 
| チェックポイントタイムアウト | 変更不可 | 該当なし | 60 分 | 
| 最大チェックポイントの保持 | 変更不可 | 該当なし | 1 | 
| チェックポイントとセーブポイントのロケーション | 変更不可 | 該当なし | 永続的なチェックポイントとセーブポイントのデータは、サービスが所有する S3 バケットに保存されます。 | 

## セーブポインティング
<a name="reference-defaults-savepoint"></a>

デフォルトでは、セーブポイントからリストアする場合、再開操作はセーブポイントのすべての状態をリストアするプログラムにマッピングしようとします。オペレータをドロップした場合、デフォルトでは、欠落したオペレータに対応するデータを含むセーブポイントからのリストアは失敗します。アプリケーションの [FlinkRunConfiguration](https://docs.aws.amazon.com/managed-flink/latest/apiv2/API_FlinkRunConfiguration.html) の *AllowNonRestoredState* パラメータを `true` に設定することで、操作を成功させることができます。これにより、再開操作は、新しいプログラムにマッピングできない状態をスキップすることができます。

詳細については、「[Apache Flink ドキュメント](https://nightlies.apache.org/flink/flink-docs-release-1.15/)」の「[復元されない状態を許可する](https://nightlies.apache.org/flink/flink-docs-release-1.15/ops/state/savepoints.html#allowing-non-restored-state)」を参照してください。

## ヒープサイズ
<a name="reference-defaults-heap"></a>

Apache Flink 用 Managed Service は、各 KPU に 3 GiB の JVM ヒープを割り当て、ネイティブコード割り当て用に1 GiB を確保します。アプリケーションの容量を増やす情報については、 [Managed Service for Apache Flink でアプリケーションスケーリングを実装する](how-scaling.md) を参照してください。

[ の詳細については、「[Apache ActiveMQ ドキュメント](https://nightlies.apache.org/flink/flink-docs-release-1.15/)」の「設定](https://nightlies.apache.org/flink/flink-docs-release-1.15/ops/config.html)」を参照してください。

## バッファデブローティング
<a name="reference-defaults-buffer-debloating"></a>

バッファデブローティングは、バックプレッシャーが高いアプリケーションに役立ちます。アプリケーションでチェックポイントやセーブポイントの失敗が発生する場合、この機能を有効にすると役に立ちます。そのためには、「[サポートケース](https://console.aws.amazon.com/support/home#/)」をリクエストしてください。

詳細については、「[Apache Flink ドキュメント](https://nightlies.apache.org/flink/flink-docs-release-1.15/)」の「[バッファデブローティングのメカニズム](https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/deployment/memory/network_mem_tuning/#the-buffer-debloating-mechanism)」を参照してください。