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


0

我试图 root据数据库中可用的某些规则从一个原始数据流中创建新的数据流。一旦我启动了Flink job,在一些之后,如果我需要 root据数据库中更新的条目创建一个新的数据流,我如何才能实现这一点呢。所以这里我不想重新启动Flink job,而是在运行时动态地创建新的数据流,并将其添加到执行DAG中。

1 答案


0

简而言之:这在运行时是不可能的。

您需要停止 job并提交新 job。


我来回答

写文章

提问题

面试题