Flink的operator chain引起的问题
今天早上在群里有人问了这样一个问题,我当时只看了截图没看他的代码,而后我俩在那聊了半天,最后发现不在一个频道,后面我仔细看了一下,他的代码明白了他的逻辑,我先简单描述一下场景,他在Flink流开始的时候直接把原数据分别sink到了es和gp库,而后把处理过的流拿了两个测流输出,最后分别把这两个测流sink到了es和gp,至关于他一共有4个sink,可是他在Flink的UI上面看到的DAG图是这样的
相关文章
- 1. 引起的问题
- 2. maven replace引起的问题
- 3. java.io.Serializable引起的问题
- 4. DateFormatter引起的问题
- 5. System.arraycopy引起的问题
- 6. System.in引起的问题
- 7. 由 TypeInitializationException 引起的问题
- 8. h5py引起的问题
- 9. Flink原理（三）——Task（任务）、Operator Chain（算子链）和Slot（资源）
- 10. 由引用引起的问题
- 更多相关文章...
- • Redis悲观锁解决高并发抢红包的问题 - 红包项目实战
- • Redis乐观锁解决高并发抢红包的问题 - 红包项目实战
- • PHP Ajax 跨域问题最佳解决方案
- • Flink 数据传输及反压详解
相关标签/搜索
每日一句
-
每一个你不满意的现在，都有一个你没有努力的曾经。
欢迎关注本站公众号,获取更多信息
