This is an automated email from the ASF dual-hosted git repository.
junrao pushed a commit to branch 3.0
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/3.0 by this push:
new 1805a0c KAFKA-13544: fix FinalizedFeatureChangeListener deadlock
(#11607)
1805a0c is described below
commit 1805a0c6360e7e3dda133e767c8587a7cd65b80a
Author: jiangyuan <[email protected]>
AuthorDate: Sat Dec 18 08:32:01 2021 +0800
KAFKA-13544: fix FinalizedFeatureChangeListener deadlock (#11607)
Reviewers: Jun Rao <[email protected]>
---
core/src/main/scala/kafka/server/FinalizedFeatureChangeListener.scala | 1 -
1 file changed, 1 deletion(-)
diff --git
a/core/src/main/scala/kafka/server/FinalizedFeatureChangeListener.scala
b/core/src/main/scala/kafka/server/FinalizedFeatureChangeListener.scala
index ac4600f..8f10ab6 100644
--- a/core/src/main/scala/kafka/server/FinalizedFeatureChangeListener.scala
+++ b/core/src/main/scala/kafka/server/FinalizedFeatureChangeListener.scala
@@ -242,7 +242,6 @@ class FinalizedFeatureChangeListener(private val
finalizedFeatureCache: Finalize
zkClient.unregisterZNodeChangeHandler(FeatureZNodeChangeHandler.path)
queue.clear()
thread.shutdown()
- thread.join()
}
// For testing only.
