java-print flink KeyedStream


0

我有一个数据流>

打印正确

当我 key,窗口,和然后打印什么都没有出来?

所以我采取我的 job 流程然后运行:

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

groupedStream.print();

stdout中什么也没有出现?

1 答案


0

大多数与执行Window操作符后输出不足有关的问题(比如95%)来自于没有正确的 watermark分配或时间戳提取。

所以:

    如果您从未在流中调用assignTimestampsAndWatermarks,那么您应该这样做。

我来回答

写文章

提问题

面试题