You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ch...@apache.org on 2020/10/18 14:18:06 UTC
[kafka] branch trunk updated: MINOR: Fix comment about
AbstractFetcherThread.handlePartitionsWithError (#7205)
This is an automated email from the ASF dual-hosted git repository.
chia7712 pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 7d7b92b MINOR: Fix comment about AbstractFetcherThread.handlePartitionsWithError (#7205)
7d7b92b is described below
commit 7d7b92b3aedab9c9955cde484e3f9d4782da0021
Author: Patrick Dignan <di...@gmail.com>
AuthorDate: Sun Oct 18 10:16:52 2020 -0400
MINOR: Fix comment about AbstractFetcherThread.handlePartitionsWithError (#7205)
Reviewers: Stanislav Kozlovski<st...@outlook.com>, William Hammond<wi...@gmail.com>, Chia-Ping Tsai<ch...@gmail.com>
---
core/src/main/scala/kafka/server/AbstractFetcherThread.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/core/src/main/scala/kafka/server/AbstractFetcherThread.scala b/core/src/main/scala/kafka/server/AbstractFetcherThread.scala
index f0a9b15..52985f9 100755
--- a/core/src/main/scala/kafka/server/AbstractFetcherThread.scala
+++ b/core/src/main/scala/kafka/server/AbstractFetcherThread.scala
@@ -306,7 +306,7 @@ abstract class AbstractFetcherThread(name: String,
inLock(partitionMapLock) {
partitionsWithError ++= partitionStates.partitionSet.asScala
// there is an error occurred while fetching partitions, sleep a while
- // note that `ReplicaFetcherThread.handlePartitionsWithError` will also introduce the same delay for every
+ // note that `AbstractFetcherThread.handlePartitionsWithError` will also introduce the same delay for every
// partition with error effectively doubling the delay. It would be good to improve this.
partitionMapCond.await(fetchBackOffMs, TimeUnit.MILLISECONDS)
}