hehuiyuan opened a new pull request #18993:
URL: https://github.com/apache/flink/pull/18993
## What is the purpose of the change
When a record arrived and the window is not exist, it will emit the
window result immediately.
` if (triggerTime(window) <= ctx.getCurrentWatermark()) {
// we are in the late phase
// if there is no late trigger then we fire on every
late element
// This also covers the case of recovery after a failure
// where the currentWatermark will be Long.MIN_VALUE
return true;
}`
I think it can use lateTrigger, if user set
"table.exec.emit.late-fire.delay".
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
