Skip to content

Conversation

jerrypeng
Copy link
Contributor

@jerrypeng jerrypeng commented Sep 27, 2025

What changes were proposed in this pull request?

Introduce a new trigger type for Real-time Mode (RTM) in Structured Streaming. This new trigger will be how users enable their Structured Streaming query to run in Real-time Mode.

Please note this PR just adds the trigger. Users cannot yet run queries in Real-time Mode. Other functionality will come in later PRs.

Why are the changes needed?

This serves as the first PR to add Real-time mode to Structured Streaming.

Does this PR introduce any user-facing change?

Yes, it adds a new trigger type to Structured Streaming. This change does not effect or change any existing behaviors.

How was this patch tested?

Unit test added.

Was this patch authored or co-authored using generative AI tooling?

No

@jerrypeng jerrypeng force-pushed the SPARK-53737 branch 2 times, most recently from 6826c97 to 98b7202 Compare September 30, 2025 16:42
@jerrypeng jerrypeng changed the title [WIP][SPARK-53737] Add Real-time Mode trigger [SPARK-53737][SQL][SS] Add Real-time Mode trigger Sep 30, 2025
Copy link
Member

@viirya viirya left a comment

Choose a reason for hiding this comment

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

Looks good to me. cc @HeartSaVioR

@viirya viirya closed this in 848e47a Oct 2, 2025
@viirya
Copy link
Member

viirya commented Oct 2, 2025

Merged to master. Thanks @jerrypeng

@jerrypeng
Copy link
Contributor Author

@viirya thank you for merging the PR in!

@dongjoon-hyun
Copy link
Member

dongjoon-hyun commented Oct 7, 2025

Thank you so much for Real-time mode trigger contribution, @jerrypeng and @viirya .

If you have more PRs in your plan, shall we have an umbrella JIRA issue to advertise your contribution actively for Apache Spark 4.1.0? Currently, I saw two PRs including this and put them under SPARK-51166 temporarily to give a better visibility, but independent umbrella JIRA issue will be perfect for you.

@viirya
Copy link
Member

viirya commented Oct 7, 2025

@jerrypeng I remember you said you created https://issues.apache.org/jira/browse/SPARK-53736 as an umbrella JIRA for real-time mode PRs. Could you put the SPARK-53737 and SPARK-53784 under it?

@viirya
Copy link
Member

viirya commented Oct 7, 2025

Thank you @dongjoon-hyun

@dongjoon-hyun
Copy link
Member

Oh, it exists. Thank you, @viirya . I'll move them to SPARK-53736 .

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