You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ju...@apache.org on 2021/12/22 19:40:13 UTC
[kafka] branch 3.1 updated: KAFKA-13544: fix FinalizedFeatureChangeListener deadlock (#11607)
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 <jo...@gmail.com>
AuthorDate: Sat Dec 18 08:32:01 2021 +0800
KAFKA-13544: fix FinalizedFeatureChangeListener deadlock (#11607)
Reviewers: Jun Rao <ju...@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.