wcarlson5 opened a new pull request, #13641: URL: https://github.com/apache/kafka/pull/13641
Add grace period to the stream table join. Add an upstream processor that acts as a buffer to establish the grace period before sending the stream records down to the join operator to preform the join. This is a separate operator for now to make it easier to slot in the versioned table optimization and then be able to use the grace period for all types of joins. This can easily change it that is not what we want. ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status - [ ] Verify documentation (including upgrade notes) -- 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: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
