Skip to content

Conversation

@rkhachatryan
Copy link
Contributor

@rkhachatryan rkhachatryan commented Dec 15, 2025

What is the purpose of the change

On timer, TimeIntervalJoin potentially performs a lot of work iterating through all it's records in state.

And when multiple timers are triggered by a single watermark, checkpoint can be delayed significantly, effectively increasing e2e latency.

Recently, splittable timers were introduced to Flink for a limited set of operators in FLINK-20217.

TimeIntervalJoin can benefit from it as well.

@flinkbot
Copy link
Collaborator

flinkbot commented Dec 15, 2025

CI report:

Bot commands The @flinkbot bot supports the following commands:
  • @flinkbot run azure re-run the last Azure build

@pnowojski
Copy link
Contributor

I think change LGTM, but doesn't it lack test coverage? Are there some an existing tests for delayed watermarks?

…termarkDelay

This refactoring removes a separate code path for watermark processing
in KeyedCoProcessOperatorWithWatermarkDelay thus enabling the use of splittable timers.
@rkhachatryan rkhachatryan marked this pull request as ready for review January 8, 2026 23:23
Copy link
Contributor Author

@rkhachatryan rkhachatryan left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I've split the commit and added a test; although it focuses mostly on postponing timers (see comment below).

@rkhachatryan
Copy link
Contributor Author

@flinkbot run azure

1 similar comment
@rkhachatryan
Copy link
Contributor Author

@flinkbot run azure

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants