(hbase) branch branch-2.5 updated: HBASE-28158 Addendum use equals instead of == (#7526)

[zh...@apache.org]

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 <zh...@apache.org>
AuthorDate: Sun Dec 7 23:01:17 2025 +0800

    HBASE-28158 Addendum use equals instead of == (#7526)
    
    Co-authored-by: Kevin Geiszler <kg...@cloudera.com>
    
    Signed-off-by: Nihal Jain <ni...@apache.org>
    Signed-off-by: Chandra Sekhar K <ch...@apache.org>
    (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());
       }
     }
   }