Flink中复杂的优化(多输入)集成测试-问答-阿里云开发者社区-阿里云

开发者社区> 问答> 正文

Flink中复杂的优化(多输入)集成测试

flink小助手 2018-12-10 13:50:29 1795

我需要为flink流式优化编写单元测试。它基本上是一个CoFlatMapFunction,它有2个输入。

我尝试从这个页面获得一些灵感:https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/testing.html

输入的顺序对我的优化很重要,所以当我测试时,我不能StreamExecutionEnvironment#fromCollection用于每个输入,因为我不会控制在每个输入中注入数据点的顺序。

我试图创建一个单独的输入使用StreamExecutionEnvironment#fromCollection并CoFlatMapFunction根据其类型将每个元素分配给我的实际输入,但是在此操作中元素的顺序会丢失。

还有其他方法可以编写此测试吗?

测试技术 流计算
分享到
取消 提交回答
全部回答(1)
大数据
使用钉钉扫一扫加入圈子
+ 订阅

大数据计算实践乐园,近距离学习前沿技术

推荐文章
相似问题