EventTimeWindows 的 Flink 最低要求

Question

使用 EventTimeWindows 的最低要求是什么？ 为什么这段代码不给出任何东西？ 如果我更改为

TumblingProcessingTimeWindows

- 一切正常。

我没有在文档中找到我必须添加的其他内容？触发器？驱逐者？ 允许迟到？

  WatermarkStrategy<UserModel> strategy = WatermarkStrategy.<UserModel>forBoundedOutOfOrderness(Duration.ofSeconds(20))
                .withTimestampAssigner((i, timestamp) -> Timestamp.valueOf(i.dt).getTime());

        ds.assignTimestampsAndWatermarks(strategy)
                .windowAll(TumblingEventTimeWindows.of(Time.seconds(10))).reduce((acc, i) -> {
                    acc.count += i.count;
                    acc.dt = i.dt;
                    return acc;
                }).addSink(new PrintSinkFunction());

输入：

{"userId":1,"count":11,"dt":"2023-04-11T09:29:12.244"}

系统时间=输入时间