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

Reply via email to