Skip to content

Fix zombie coordinator thread when S3 writes fail#16020

Open
utafrali wants to merge 1 commit intoapache:mainfrom
utafrali:fix/issue-16016-iceberg-kafka-connect-zombie-coordinator
Open

Fix zombie coordinator thread when S3 writes fail#16020
utafrali wants to merge 1 commit intoapache:mainfrom
utafrali:fix/issue-16016-iceberg-kafka-connect-zombie-coordinator

Conversation

@utafrali
Copy link
Copy Markdown

Fixes #16016

When S3 writes failed, the coordinator thread wouldn't properly terminate because nothing was waiting for it, leaving a zombie. Fixed by joining the thread after calling terminate() and wrapping the cleanup in try-finally so the catalog gets closed even if the committer shutdown fails.

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.

iceberg-kafka-connect zombie coordinator thread when writing to S3 fails

1 participant