closed to.
-- --
??: "Hequn Cheng";
: 2019??7??14??(??) 11:49
??: "Ever"<439674...@qq.com>;
????: "user";
????: Re: [flink 1.8.1]window closed unexpectedly and data drop
Hi Ever,
The window only fires when the watermark passes
Hi Ever,
The window only fires when the watermark passes the end of a window.
> now the fourth data came with timestamp:03:17:55, at that time, a new
window should be open, and the previous window should closed
The previous window may not close if the watermark hasn't passed the end of
the wind
I have a streaming job based on Event time, which has a 60 seconds window and
10 seconds sliding window.
Data will come in batches every 10 second.
Here's the code.
```
val env = StreamExecutionEnvironment.getExecutionEnvironment
env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime)
env
