java - 如何在 Flink 中获取另一份作业的作业结果？

Question

关闭。这个问题需要details or clarity .它目前不接受答案。












想改进这个问题？通过 editing this post 添加详细信息并澄清问题.

4年前关闭。




Improve this question




情况是这样的。我有两个数据源，一个消息队列和一个MySQL表，可以分别看成DataStream和DataSet。我想基于DataStream启动一个作业，从消息队列中拉取数据并进行一些计算。在计算过程中，需要一个基于 DataSet(MySQL 表)的作业，其 OutputFormat 应将结果返回给 DataStream 作业。
我被困在这里，需要一些帮助。

Answer 1

您不能在同一个作业中混合使用 DataStream 和 DataSet API。但是有一些方法可以从流式作业中访问 MySQL。你可以:

从平面图查询 MySQL

使用异步 i/o 更有效地做到这一点

使用类似 debezium 的方式从 mysql 流式传输数据

根据您希望如何将数据从 mysql 连接到其他流，您可能需要使用 CoFlatmapFunction 或 CoProcessFunction。