This is an automated email from the ASF dual-hosted git repository.
zhangduo pushed a commit to branch branch-2.5
in repository https://gitbox.apache.org/repos/asf/hbase.git
The following commit(s) were added to refs/heads/branch-2.5 by this push:
new 1e80aecf0ee HBASE-28158 Addendum use equals instead of == (#7526)
1e80aecf0ee is described below
commit 1e80aecf0ee787849ec2733f7b2caa8fe4ce4b01
Author: Duo Zhang <[email protected]>
AuthorDate: Sun Dec 7 23:01:17 2025 +0800
HBASE-28158 Addendum use equals instead of == (#7526)
Co-authored-by: Kevin Geiszler <[email protected]>
Signed-off-by: Nihal Jain <[email protected]>
Signed-off-by: Chandra Sekhar K <[email protected]>
(cherry picked from commit a2a35aaa68eadc738cfc7c1db5a1f0139e0e69df)
---
.../apache/hadoop/hbase/master/assignment/AssignmentManager.java | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
diff --git
a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/assignment/AssignmentManager.java
b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/assignment/AssignmentManager.java
index b811791a8f4..ef0a1ddfbcb 100644
---
a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/assignment/AssignmentManager.java
+++
b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/assignment/AssignmentManager.java
@@ -2216,11 +2216,15 @@ public class AssignmentManager {
public void markRegionsAsCrashed(List<RegionInfo> regionsOnCrashedServer,
ServerCrashProcedure scp) {
ServerName crashedServerName = scp.getServerName();
+ assert crashedServerName != null;
for (RegionInfo regionInfo : regionsOnCrashedServer) {
RegionStateNode node =
regionStates.getOrCreateRegionStateNode(regionInfo);
- if (node.getRegionLocation() == crashedServerName) {
+ if (crashedServerName.equals(node.getRegionLocation())) {
node.crashed(scp.getSubmittedTime());
regionInTransitionTracker.regionCrashed(node);
+ } else {
+ LOG.warn("Region {} should be on crashed region server {} but is
recorded on {}", regionInfo,
+ crashedServerName, node.getRegionLocation());
}
}
}