Apache Flink：在多个Kafka分区中使用事件时间时没有输出

Question

java prettyprint-override">stream.assignTimestampsAndWatermarks(new AscendingTimestampExtractor<Request>() {
    @Override
    public long extractAscendingTimestamp(Request req) {
        return req.ts;
    }
})
.windowAll(TumblingEventTimeWindows.of(Time.days(1)))
.apply((TimeWindow window, Iterable<Request> iterable, Collector<String> collector) -> {
    collector.collect("Window: " + window.toString());
    for (Request req : iterable) {
        collector.collect(req.toString());
    }
})
.print()

因此，我将AscendingTimeStampExtractor替换为BoundedOutoFordernessGenerator，就像在这个文档示例中一样（具有更高的maxOutOfOrderness延迟），以便处理乱序事件，但我仍然无法获得任何输出。这是为什么？

Answer 1

检查事件时间戳是否正常。必须有13的长度才能在Flink Java Epoch中使用。

更正：1563743505673

错误：1563743505