Skip to content

Enable real-time clock in prism by default. - #36473

Merged
shunping merged 3 commits into
apache:masterfrom
shunping:prism-enable-rtc
Oct 13, 2025
Merged

Enable real-time clock in prism by default.#36473
shunping merged 3 commits into
apache:masterfrom
shunping:prism-enable-rtc

Conversation

@shunping

@shunping shunping commented Oct 10, 2025

Copy link
Copy Markdown
Collaborator

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
Copy Markdown
Collaborator Author

R: @damccorm

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

Copy link
Copy Markdown
Collaborator Author

CC: @lostluck

@github-actions

Copy link
Copy Markdown
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

@damccorm damccorm left a comment

Copy link
Copy Markdown
Contributor

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
Copy Markdown
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
Copy Markdown
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
Copy Markdown
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
Copy Markdown
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

shunping commented Nov 6, 2025

Copy link
Copy Markdown
Collaborator Author

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