2

データベースで利用可能な特定のルールに基づいて、1 つの生データストリームから新しいデータストリームを作成しようとしています。Flink ジョブを開始した後、データベースの更新されたエントリに従って新しいデータストリームを作成する必要がある場合、どうすればそれを達成できますか。したがって、ここでは Flink ジョブを再起動するのではなく、実行時に新しいデータストリームを動的に作成し、それを実行 DAG に追加したいと考えています。

4

1 に答える 1

1

簡単な答え: これは実行時には不可能です。

ジョブを停止して、新しいジョブを送信する必要があります。

于 2016-06-28T10:19:03.560 に答える