-
Notifications
You must be signed in to change notification settings - Fork 28.3k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[SPARK-45582][SS] Ensure that store instance is not used after calling commit within output mode streaming aggregation #43413
Conversation
…mmit within output mode streaming aggregation
@HeartSaVioR - PTAL, thx ! |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
+1 Nice finding!
@HeartSaVioR - failure seems same as Kafka one couple days back. Will retry running the action again |
@anishshri-db We wasn't lucky. Could you push a empty commit to retrigger CI? |
@HeartSaVioR - I don't think the failure is related to my change
I ran the tests locally and they seem fine
So seems like some flakiness on this test |
cc. @rangadi |
I'm going to merge this as the test failure is not related. Thanks! Merging to master. |
@HeartSaVioR thanks. I hadn't see the flake with Protobuf tests. Will take a look. |
What changes were proposed in this pull request?
Ensure that store instance is not used after calling commit within output mode streaming aggregation
Why are the changes needed?
Without these changes, we were accessing the store instance to retrieve the iterator even after the commit was called. When commit is called, we release the DB instance lock. So its possible task retries can acquire the instance lock and close the DB instance. So when the original thread tries to access the DB, it might run into a null pointer exception. This change fixes the issue
Does this PR introduce any user-facing change?
No
How was this patch tested?
RocksDBStreamingAggregationSuite
StreamingSessionWindowSuite
Was this patch authored or co-authored using generative AI tooling?
No