java - 打印flink KeyedStream

Question

我有一个DataStream<Tuple2<String, Integer>>

打印正确

当我键入、窗口、求和然后打印时什么也没有出现？

所以我开始我的工作流 stream然后运行:

DataStream<Tuple2<String, Integer>> groupedStream = stream
        .keyBy(0)
        .window(TumblingEventTimeWindows.of(Time.seconds(5)))
        .sum(1);

groupedStream.print();

stdout 中没有出现任何内容？我该如何调试这个？

Answer 1

大多数问题(例如 95%)与执行 Window 运算符后缺乏输出有关，原因在于您没有正确的水印分配或时间戳提取。

所以:

1. 如果您从未在您的直播中调用过assignTimestampsAndWatermarks，那么您应该这样做。

2. 如果您使用了AssignedWithPeriodicWatermark，那么您应该确保setAutoWatermarkInterval() 未设置为 0。

3. 验证是否可以正确生成水印(即您的测试数据跨度超过 5 秒)

4. 此外，作为安全检查，可能值得验证这是否适用于并行度等于 1 的情况。