You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by sh...@apache.org on 2024/04/12 00:36:40 UTC
(kafka) branch trunk updated: MINOR: remove redundant argument in log (#15699)
This is an automated email from the ASF dual-hosted git repository.
showuon 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 315cd830486 MINOR: remove redundant argument in log (#15699)
315cd830486 is described below
commit 315cd830486a68f899ff50b25f8e2143564b426b
Author: Kuan-Po (Cooper) Tseng <br...@gmail.com>
AuthorDate: Fri Apr 12 08:36:33 2024 +0800
MINOR: remove redundant argument in log (#15699)
remove redundant argument in log
Reviewers: Luke Chen <sh...@gmail.com>, Chia-Ping Tsai <ch...@gmail.com>
---
.../java/org/apache/kafka/controller/ReplicationControlManager.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java b/metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java
index 8beca098b9a..f5f6e2d3200 100644
--- a/metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java
+++ b/metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java
@@ -2288,7 +2288,7 @@ public class ReplicationControlManager {
Arrays.stream(newPartInfo.elr).forEach(validationSet::add);
if (validationSet.size() != newPartInfo.isr.length + newPartInfo.elr.length) {
log.error("{}-{} has overlapping ISR={} and ELR={}", topics.get(topicId).name, partitionId,
- Arrays.toString(newPartInfo.isr), partitionId, Arrays.toString(newPartInfo.elr));
+ Arrays.toString(newPartInfo.isr), Arrays.toString(newPartInfo.elr));
}
brokersToIsrs.update(topicId, partitionId, prevPartInfo == null ? null : prevPartInfo.isr,
newPartInfo.isr, prevPartInfo == null ? NO_LEADER : prevPartInfo.leader, newPartInfo.leader);