关闭。这个问题需要details or clarity .它目前不接受答案。
想改进这个问题?通过 editing this post 添加详细信息并澄清问题.
4年前关闭。
Improve this question
情况是这样的。我有两个数据源,一个消息队列和一个MySQL表,可以分别看成DataStream和DataSet。我想基于DataStream启动一个作业,从消息队列中拉取数据并进行一些计算。在计算过程中,需要一个基于 DataSet(MySQL 表)的作业,其 OutputFormat 应将结果返回给 DataStream 作业。
我被困在这里,需要一些帮助。
最佳答案
您不能在同一个作业中混合使用 DataStream 和 DataSet API。但是有一些方法可以从流式作业中访问 MySQL。你可以:
根据您希望如何将数据从 mysql 连接到其他流,您可能需要使用 CoFlatmapFunction 或 CoProcessFunction。
关于java - 如何在 Flink 中获取另一份作业的作业结果?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/45807199/