Dynamic stream handling

[Ever]

flink的job，一般在提交到taskmanager之前， 会构建好执行图，此后这个执行图就不再改变。 

有一些场景， 需要flink job在运行期间能动态改变执行图， 例如要求split分支增加或者减少(通过side-output stream)。类似akka-stream的Dynamic Stream。

https://doc.akka.io/docs/akka/current/stream/stream-dynamic.html

目前flink有类似的功能吗?

[星沉]

On 2019/10/1 10:58 下午, Ever wrote:
> 有一些场景， 需要flink job在运行期间能动态改变执行图， 例如要求split分支
> 增加或者减少(通过side-output stream)

flink应该不支持在runtime动态更改流。