使用多个事件流对 Flink 流进行单元测试

Question

我有 2 个DataStream，我连接并馈送到一个CoFlatMap函数中。我需要能够在两个不同的DataStream上测试生成消息，但在消息到达时进行协调。如何在 Flink 中做到这一点？

Answer 1

我最终选择了：https://github.com/ottogroup/flink-spector/

文档可以使用一些更新，但总的来说它运行良好。这是pom.xml条目：

<dependency>
<groupId>io.flinkspector</groupId>
<artifactId>flinkspector-datastream_2.11</artifactId>
<version>0.8.3</version>
<scope>test</scope>
</dependency>

Answer 2

看看官方的单元测试指南。特别是检查有关使用TestHarness的最后段落。在您的情况下，似乎您应该使用TwoInputStreamOperatorTestHarness。您可以在CoProcessOperatorTest中找到如何使用它的示例