You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by st...@apache.org on 2011/01/05 01:01:56 UTC

svn commit: r1055248 - in /hbase/trunk: CHANGES.txt src/main/java/org/apache/hadoop/hbase/master/AssignmentManager.java

Author: stack
Date: Wed Jan  5 00:01:56 2011
New Revision: 1055248

URL: http://svn.apache.org/viewvc?rev=1055248&view=rev
Log:
HBASE-3408 AssignmentManager NullPointerException

Modified:
    hbase/trunk/CHANGES.txt
    hbase/trunk/src/main/java/org/apache/hadoop/hbase/master/AssignmentManager.java

Modified: hbase/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hbase/trunk/CHANGES.txt?rev=1055248&r1=1055247&r2=1055248&view=diff
==============================================================================
--- hbase/trunk/CHANGES.txt (original)
+++ hbase/trunk/CHANGES.txt Wed Jan  5 00:01:56 2011
@@ -812,6 +812,7 @@ Release 0.90.0 - Unreleased
    HBASE-3383  [0.90RC1] bin/hbase script displays "no such file" warning on
                target/cached_classpath.txt
    HBASE-3344  Master aborts after RPC to server that was shutting down
+   HBASE-3408  AssignmentManager NullPointerException
 
 
   IMPROVEMENTS

Modified: hbase/trunk/src/main/java/org/apache/hadoop/hbase/master/AssignmentManager.java
URL: http://svn.apache.org/viewvc/hbase/trunk/src/main/java/org/apache/hadoop/hbase/master/AssignmentManager.java?rev=1055248&r1=1055247&r2=1055248&view=diff
==============================================================================
--- hbase/trunk/src/main/java/org/apache/hadoop/hbase/master/AssignmentManager.java (original)
+++ hbase/trunk/src/main/java/org/apache/hadoop/hbase/master/AssignmentManager.java Wed Jan  5 00:01:56 2011
@@ -21,8 +21,8 @@ package org.apache.hadoop.hbase.master;
 
 import java.io.DataInput;
 import java.io.DataOutput;
-import java.io.IOException;
 import java.io.EOFException;
+import java.io.IOException;
 import java.net.ConnectException;
 import java.util.ArrayList;
 import java.util.HashMap;
@@ -1005,8 +1005,9 @@ public class AssignmentManager extends Z
     RegionPlan existingPlan = null;
     synchronized (this.regionPlans) {
       existingPlan = this.regionPlans.get(encodedName);
-      if (existingPlan == null || forceNewPlan ||
-          (existingPlan != null && existingPlan.getDestination().equals(serverToExclude))) {
+      if (forceNewPlan || existingPlan == null 
+              || existingPlan.getDestination() == null 
+              || existingPlan.getDestination().equals(serverToExclude)) {
         newPlan = true;
         this.regionPlans.put(encodedName, randomPlan);
       }