开发者社区 问答 正文

Dynamic stream handling?

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有类似的功能吗?*来自志愿者整理的flink邮件归档

展开
收起
彗星halation 2021-12-08 10:09:37 690 分享
分享
版权
举报
1 条回答
写回答
取消 提交回答
  • flink应该不支持在runtime动态更改流。*来自志愿者整理的flink邮件归档

    2021-12-08 10:39:20 举报
    赞同 评论

    评论

    全部评论 (0)

    登录后可评论
问答地址:
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等