You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by jx...@apache.org on 2012/07/14 04:24:44 UTC
svn commit: r1361470 -
/hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/mapreduce/replication/VerifyReplication.java
Author: jxiang
Date: Sat Jul 14 02:24:43 2012
New Revision: 1361470
URL: http://svn.apache.org/viewvc?rev=1361470&view=rev
Log:
HBASE-6394 verifyrep MR job map tasks throws NullPointerException
Modified:
hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/mapreduce/replication/VerifyReplication.java
Modified: hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/mapreduce/replication/VerifyReplication.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/mapreduce/replication/VerifyReplication.java?rev=1361470&r1=1361469&r2=1361470&view=diff
==============================================================================
--- hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/mapreduce/replication/VerifyReplication.java (original)
+++ hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/mapreduce/replication/VerifyReplication.java Sat Jul 14 02:24:43 2012
@@ -35,7 +35,6 @@ import org.apache.hadoop.hbase.client.Pu
import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.client.ResultScanner;
import org.apache.hadoop.hbase.client.Scan;
-import org.apache.hadoop.hbase.client.replication.ReplicationAdmin;
import org.apache.hadoop.hbase.io.ImmutableBytesWritable;
import org.apache.hadoop.hbase.mapreduce.TableInputFormat;
import org.apache.hadoop.hbase.mapreduce.TableMapReduceUtil;
@@ -137,7 +136,10 @@ public class VerifyReplication {
}
protected void cleanup(Context context) {
- replicatedScanner.close();
+ if (replicatedScanner != null) {
+ replicatedScanner.close();
+ replicatedScanner = null;
+ }
}
}