Flink 单元测试

Question

我需要对基于数据流的 flink 管道进行单元测试。我有一个 rmq 源、丰富器、过滤器、聚合器，然后是滚动窗口。我犯规了，我们可以通过两种方式进行测试，

1. 使用测试工具
2. 使用flink频谱

如何选择？什么最适合弹簧集成测试。 ？

Answer 1

没有一种“最佳”测试方法。

1. 您可以使用 Flink 的测试工具来测试各个操作员。
2. 您使用假源（或像

   StreamExecutionEnvironment.fromData()

   这样的内置支持为您的工作流程提供一组预定义的输入数据，然后使用模拟接收器捕获并验证结果。
3. 您可以使用真正的 RMQ 源和您正在使用的任何接收器进行完整的集成测试，但这通常意味着启动一个容器，并需要额外的工作来加载带有测试数据的源。

请参阅 Flink 的测试指南了解更多详细信息。