Flinkの別のジョブでジョブの結果を取得する方法は？

Question

ここに状況があります。
私は2つのデータソースを持っています。メッセージキューとMySQLテーブルはそれぞれDataStreamとDataSetと見なすことができます。DataStreamに基づいてジョブを開始して、メッセージキューからデータを取り出して計算を実行したいとします。計算の進行中に、DataSet（MySQLテーブル）に基づくジョブが必要です。そのジョブのOutputFormatは、結果をDataStreamジョブに返す必要があります。
私はここにこだわっていて、助けが必要です。

Answer 1

DataStream APIとDataSet APIを同じジョブで混在させることはできません。しかし、ストリーミングジョブからMySQLにアクセスする方法があります。次のことができますどのようにあなたによってdebezium

のようなものを使用してMySQLからのデータでストリーム

より効率的にこれを行うには、I/O非同期flatmap

使用から

1. クエリMySQLをmysqlから他のストリームにデータを接続したい場合は、CoFlatmapFunctionまたはCoProcessFunctionを使用することができます。