flinkで正確なホストで実行する操作を実行します

Question

同じノード内で実行するには、flinkジョブのソースと出力ストリームが必要です。それを行う方法はありますか？

Answer 1

Flink（> 1.0.0）で行う方法があります。

このリンクを確認してくださいDataStream API - Task Chaining。 特に、slotSharingGroup() APIを使用できます。

これは、あなたが望むものを正確に行う演算子のコロケーションを可能にします。