apache-flink - 在 Flink 中动态创建新的数据流

Question

我正在尝试根据数据库中可用的某些规则从一个原始数据流中创建新的数据流。一旦我开始 Flink 作业，之后，如果我需要根据数据库中更新的条目创建一个新的数据流，我该如何实现。所以这里我不想重启 Flink 作业，而是在运行时动态创建新的数据流并将其添加到执行 DAG 中。

Answer 1

简短的回答：这在运行时是不可能的。

您需要停止作业并提交新作业。