具有多个事件流的单元测试Flink流
我有2个数据流，我将其连接并输入到一个CoFlatMap函数中。我需要能够在两个不同的数据流上测试生成消息，但在消息到达时进行协调。在Flink如何做到这一点？
共有2个答案
看看官方的单元测试指南。特别检查关于使用TestHarness的最后几段。在您的情况下，似乎应该使用TwoInputStreamOperatorTestHarness。您可以在协处理器测试中找到如何使用它的示例
我最终选择了：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>
-
我正在尝试为我的Spark流作业编写单元测试。我的spark streaming作业使用来自的消息，并将其推入主题。 我的方法是 null
-
<代码>list.stream（）。 列表中的每个项目都将从数据库中删除。 假设列表中有3个项目，如何进行单元测试： 删除被调用了3次。 删除被称为“按顺序/顺序”，即列表中的元素顺序？
-
参数化测试可以将不同的数据输入到测试中。不过，我创建了一个示例计算器，希望为其创建参数化测试。但是，我发现您只能为单个测试创建一组参数化数据。 我已经创建了参数化测试，用于添加两个数字，得到预期的结果。由于预期结果会有所不同，因此该数据将不适用于减法运算。 有没有可能为每个加、减、乘、除测试提供参数化数据？ 非常感谢您的建议，
-
为了让单元测试跑一个批处理的任务，这个框架必须加载这个任务的ApplicationContext,两个注解的触发方式： @RunWith(SpringJUnit4ClassRunner.class):表明这个类需要使用Spring的测试工具 @ContextConfiguration(locations = {…}):表明哪些xml文件包含ApplicationContext @RunWith
-
我试图开发以下代码，但它不起作用。我想使用apache Flink来延迟时间（在时间戳字段中指定的）与当前日期不同的事件。 样品： > 当前日期：2022-05-06 10:30 事件1[{“user1”：“1”，“user2”：“2”，“timestamp”：“2022-05-06 10:30”}-- 事件2[{“user1”：“1”，“user2”：“2”，“timestamp”：“2022-
-
我有一个类处理一个图像，这可能是一个缓慢的过程。当工作完成时，该类包含图像的一些特性，如主色。 我有许多其他的代码想知道主颜色，当他们要求它时，它可能是或可能没有准备好。 我还没有找到使用RXJava2实现这一点的简单方法。有人能帮帮我吗？ null ReplaySubject似乎有一些我正在寻找的属性，但我不确定如何正确地实现它。