-
Type:
Improvement
-
Status: Open
-
Priority:
Minor
-
Resolution: Unresolved
-
Affects Version/s: None
-
Fix Version/s: None
-
Component/s: API / DataStream
-
Labels:
srcStream .timeWindowAll(Time.seconds(60)) .trigger(ContinuousProcessingTimeTrigger.of(Time.seconds(10)))...
This can correctly calculate the following interval result : 0-10s 10-20s 20-30s 30-40s 40-50s
But this lost data which was send in 50-60s.
Because when the first window ends, the time is 59.9999s, it is not equal to window-end-time(60s).So it will not enter the if judgment.
- links to