Skip to content

[SPARK-49930][SS] Ensure that socket updates are flushed on exception from the python worker#48418

Closed
anishshri-db wants to merge 1 commit intoapache:masterfrom
anishshri-db:task/SPARK-49930
Closed

[SPARK-49930][SS] Ensure that socket updates are flushed on exception from the python worker#48418
anishshri-db wants to merge 1 commit intoapache:masterfrom
anishshri-db:task/SPARK-49930

Conversation

@anishshri-db
Copy link
Contributor

What changes were proposed in this pull request?

Ensure that socket updates are flushed on exception from the python worker

Why are the changes needed?

Without this, updates to the socket from the python worker are not delivered to the jvm side

Does this PR introduce any user-facing change?

No

How was this patch tested?

Existing tests were failing on a different Python version and pass after

Run completed in 1 minute, 13 seconds.
Total number of tests run: 8
Suites: completed 1, aborted 0
Tests: succeeded 8, failed 0, canceled 0, ignored 0, pending 0
All tests passed.

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

No

@anishshri-db
Copy link
Contributor Author

cc - @HeartSaVioR @WweiL - PTAL, thx !

@anishshri-db anishshri-db changed the title [SPARK-49930] Ensure that socket updates are flushed on exception from the python worker [SPARK-49930][SS] Ensure that socket updates are flushed on exception from the python worker Oct 11, 2024
@HyukjinKwon
Copy link
Member

Merged to master.

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.

2 participants