您好，下面是个人理解：
首先，这个问题不是Session窗口的问题，滚动和滑动是一样的。
时间窗口的计算输出是由时间特性确定的，目前
1. 只有processing-time即处理时间（没有水位线处理乱序）能够满足及时输出窗口的结果。
2.
把eventtime的水位线时间戳设置为System.currentTimeMillis()也是可以及时输出窗口的结果，但是只会消费Flink程序启动后接收到的新消息，之前的消息是处理不到的，即便是新的消费者组group.id和earliest也无效【意思就是容错和重播失效，当然还可以再反复验证】。
目前EventTime-事件时间做到实时
各位大神，你们好：
最近有一个问题一直困扰着我：我设置的会话窗口，会在非活动状态10s后结束
窗口，发现它会在下次窗口生成时才发送本窗口处理完的数据，而我想在本次窗口结束
时发送这个数据，应该如何处理？万分感激
// 这里配置了kafka的信息，并进行数据流的输入
env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime);
FlinkKafkaConsumer010 kafkaSource = new
FlinkKafkaConsumer010<>("rfid-input-t
