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 2013/02/01 07:59:14 UTC
svn commit: r1441321 -
/hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/master/SplitLogManager.java
Author: stack
Date: Fri Feb 1 06:59:14 2013
New Revision: 1441321
URL: http://svn.apache.org/viewvc?rev=1441321&view=rev
Log:
HBASE-3890 Scheduled tasks in distributed log splitting not in sync with ZK
Modified:
hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/master/SplitLogManager.java
Modified: hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/master/SplitLogManager.java
URL: http://svn.apache.org/viewvc/hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/master/SplitLogManager.java?rev=1441321&r1=1441320&r2=1441321&view=diff
==============================================================================
--- hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/master/SplitLogManager.java (original)
+++ hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/master/SplitLogManager.java Fri Feb 1 06:59:14 2013
@@ -53,7 +53,6 @@ import org.apache.hadoop.hbase.monitorin
import org.apache.hadoop.hbase.monitoring.TaskMonitor;
import org.apache.hadoop.hbase.regionserver.SplitLogWorker;
import org.apache.hadoop.hbase.regionserver.wal.HLogSplitter;
-import org.apache.hadoop.hbase.regionserver.wal.HLogUtil;
import org.apache.hadoop.hbase.util.EnvironmentEdgeManager;
import org.apache.hadoop.hbase.util.FSUtils;
import org.apache.hadoop.hbase.util.Threads;
@@ -885,7 +884,7 @@ public class SplitLogManager extends Zoo
volatile long last_update;
volatile int last_version;
volatile ServerName cur_worker_name;
- TaskBatch batch;
+ volatile TaskBatch batch;
volatile TerminationStatus status;
volatile int incarnation;
volatile int unforcedResubmits;
@@ -1182,7 +1181,7 @@ public class SplitLogManager extends Zoo
}
return;
} else {
- LOG.debug(path +
+ LOG.info(path +
" does not exist. Either was created but deleted behind our" +
" back by another pending delete OR was deleted" +
" in earlier retry rounds. zkretries = " + (Long) ctx);