This is an automated email from the ASF dual-hosted git repository.
junrao pushed a commit to branch 2.8
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/2.8 by this push:
new 52aaca0 KAFKA-13544: fix FinalizedFeatureChangeListener deadlock
(#11607)
52aaca0 is described below
commit 52aaca01eb1c12cf2c28141f56535becaf026705
Author: jiangyuan <joe469391...@gmail.com>
AuthorDate: Sat Dec 18 08:32:01 2021 +0800
KAFKA-13544: fix FinalizedFeatureChangeListener deadlock (#11607)
Reviewers: Jun Rao <jun...@gmail.com>
---
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.
