Cheng Pan created SPARK-58714:
---------------------------------
Summary: Fix AdminClient leak in KafkaTokenUtil.obtainToken
Key: SPARK-58714
URL: https://issues.apache.org/jira/browse/SPARK-58714
Project: Spark
Issue Type: Bug
Components: Structured Streaming
Affects Versions: 5.0.0
Reporter: Cheng Pan
KafkaTokenUtil.obtainToken creates an AdminClient but never closes it, on
either the success or the exception path. Each token obtain cycle (per cluster,
per renewal) and each failed attempt leaks the client's network thread and
sockets in long-running drivers.
Introduced by SPARK-25501 (Spark 3.0.0); affects all releases since (3.0.0 -
4.2.0).
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
