This is an automated email from the ASF dual-hosted git repository.
cmccabe 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 13946759007 MINOR: Add unclean field of PartitionReassignmentRevert to
hashCode Equals and toString (#13370)
13946759007 is described below
commit 139467590074599a814c55f4907a042b68ea50d7
Author: andymg3 <[email protected]>
AuthorDate: Thu Mar 9 13:26:41 2023 -0500
MINOR: Add unclean field of PartitionReassignmentRevert to hashCode Equals
and toString (#13370)
Reviewers: Colin P. McCabe <[email protected]>
---
.../org/apache/kafka/controller/PartitionReassignmentRevert.java | 8 +++++---
1 file changed, 5 insertions(+), 3 deletions(-)
diff --git
a/metadata/src/main/java/org/apache/kafka/controller/PartitionReassignmentRevert.java
b/metadata/src/main/java/org/apache/kafka/controller/PartitionReassignmentRevert.java
index 3cf6dbb4562..bdcb7991486 100644
---
a/metadata/src/main/java/org/apache/kafka/controller/PartitionReassignmentRevert.java
+++
b/metadata/src/main/java/org/apache/kafka/controller/PartitionReassignmentRevert.java
@@ -85,7 +85,7 @@ class PartitionReassignmentRevert {
@Override
public int hashCode() {
- return Objects.hash(replicas, isr);
+ return Objects.hash(replicas, isr, unclean);
}
@Override
@@ -93,13 +93,15 @@ class PartitionReassignmentRevert {
if (!(o instanceof PartitionReassignmentRevert)) return false;
PartitionReassignmentRevert other = (PartitionReassignmentRevert) o;
return replicas.equals(other.replicas) &&
- isr.equals(other.isr);
+ isr.equals(other.isr) &&
+ unclean == other.unclean;
}
@Override
public String toString() {
return "PartitionReassignmentRevert(" +
"replicas=" + replicas + ", " +
- "isr=" + isr + ")";
+ "isr=" + isr + ", " +
+ "unclean=" + unclean + ")";
}
}