Flink时间关联（temporaljoin）未显示数据

1. 确认时间关联的时间窗口是否正确，包括是否对窗口时间进行了转换。
2. 确认输入数据是否正确且包含了时间戳字段。
3. 确认时间窗口是否正确地与 keys 或者其他条件连接在一起。
4. 确认输入数据的事件时间是否正确（例如，数据跨越了多个时区），可以使用 Event Time 窗口，并使用 Watermark 进行处理。
5. 确认 join 算子是否启用 inner join 模式，如果是外部 join，则有可能出现未显示数据的问题。

示例代码：

// 创建事件流，且每个事件都包含了一个时间戳 DataStream<Event> stream1 = env.fromElements( new Event(1, "event1", 1610200001000L), new Event(2, "event2", 1610200101000L), new Event(3, "event3", 1610200201000L), new Event(4, "event4", 1610200301000L) );

// 另一个事件流 DataStream<Event> stream2 = env.fromElements( new Event(1, "event1", 1610200005000L), new Event(2, "event2", 1610200105000L), new Event(3, "event3", 1610200205000L), new Event(4, "event4", 1610200305000L) );

// 通过 connect 连接两个事件流，并为每个事件创建一个时间窗口进行时间关联 DataStream<Tuple2<Event, Event>> result = stream1 .keyBy(event -> event.eventId) // 将每个事件按照 ID 进行分组 .intervalJoin(stream2.keyBy(event -> event.eventId)) // 进行时间关联 .between(Time.seconds(-5), Time.seconds(5)) // 进行 -5s 到 5s 的关联 .process(new