Skip to content

Conversation

@shunping
Copy link
Collaborator

@shunping shunping commented Oct 10, 2025

Also adjust some processing time timer tests so that they can finish before server timeout.

@shunping shunping changed the title Enable real-time clock in prism by default. [WIP] Enable real-time clock in prism by default. Oct 10, 2025
@shunping
Copy link
Collaborator Author

R: @damccorm

@shunping shunping marked this pull request as ready for review October 11, 2025 02:38
@shunping
Copy link
Collaborator Author

CC: @lostluck

@github-actions
Copy link
Contributor

Stopping reviewer notifications for this pull request: review requested by someone other than the bot, ceding control. If you'd like to restart, comment assign set of reviewers

@shunping shunping self-assigned this Oct 11, 2025
@shunping shunping requested a review from damccorm October 11, 2025 02:39
@shunping shunping changed the title [WIP] Enable real-time clock in prism by default. Enable real-time clock in prism by default. Oct 11, 2025
Copy link
Contributor

@damccorm damccorm left a comment

Choose a reason for hiding this comment

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

This seems good to me, but my ability to review thoroughly is somewhat limited. @lostluck if you're able to take a look, that would be awesome. If not, let me know and I'll merge for now

@lostluck
Copy link
Contributor

I am going to get to it today.

timersProcessingTimePipelineBuilder(func(s beam.Scope) beam.PCollection {
now := time.Now()
return periodic.Impulse(s, now, now.Add(10*time.Second), 0, false)
return periodic.Impulse(s, now, now.Add(10*time.Second), 5*time.Second, false)
Copy link
Contributor

Choose a reason for hiding this comment

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

Is the goal here is to have the transform fire twice, not once?

Copy link
Collaborator Author

Choose a reason for hiding this comment

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

Exactly!

@shunping
Copy link
Collaborator Author

Thanks a lot for your time to review!

@shunping shunping merged commit 554a73b into apache:master Oct 13, 2025
14 checks passed
@shunping
Copy link
Collaborator Author

shunping commented Nov 6, 2025

After this PR, real-time clock is enabled in prism by default. So I think we can close #32786.

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

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants