mblesak commented on issue #13593: URL: https://github.com/apache/iceberg/issues/13593#issuecomment-3109175466
Thanks @kumarpritam863 for your responses. IcebergSinkTask.close() and IcebergSinkTask.stop() are referring the same method: CommiterImpl.close(). When connector initiate **IcebergSinkTask.stop()** the CommiterImpl.close() can fail (_clientFactory_ is null, _context_ is null) or there can be situation when consumer group is not in STABLE state anymore while condition is checking partition assignment. Those are points when Committer's background thread is not terminated and continue operates with closed Catalog. Do you see visible to return back method: CommiterImpl.stop() which will just does: stopCoordinator() and stopWorker() ? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@iceberg.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org --------------------------------------------------------------------- To unsubscribe, e-mail: issues-unsubscr...@iceberg.apache.org For additional commands, e-mail: issues-h...@iceberg.apache.org