This is an automated email from the ASF dual-hosted git repository.
junrao pushed a commit to branch 3.1
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/3.1 by this push:
new 8f8fa60 KAFKA-13544: fix FinalizedFeatureChangeListener deadlock
(#11607)
8f8fa60 is described below
commit 8f8fa6028d327e4749f15eb8f6fd66f47e5c06b1
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.
