Apache/hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-3890 Scheduled tasks in distributed log splitting not in sync with ZK

Browse Source 
git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1441321 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Michael Stack 2013-02-01 06:59:14 +00:00
parent 2ade85d0b8
commit 6657449eb4
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
hbase-server/src/main/java/org/apache/hadoop/hbase/master/SplitLogManager.java
View File

@ -53,7 +53,6 @@ import org.apache.hadoop.hbase.monitoring.MonitoredTask;
import org.apache.hadoop.hbase.monitoring.TaskMonitor; import org.apache.hadoop.hbase.monitoring.TaskMonitor;
import org.apache.hadoop.hbase.regionserver.SplitLogWorker; import org.apache.hadoop.hbase.regionserver.SplitLogWorker;
import org.apache.hadoop.hbase.regionserver.wal.HLogSplitter; 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.EnvironmentEdgeManager;
import org.apache.hadoop.hbase.util.FSUtils; import org.apache.hadoop.hbase.util.FSUtils;
import org.apache.hadoop.hbase.util.Threads; import org.apache.hadoop.hbase.util.Threads;
@ -885,7 +884,7 @@ public class SplitLogManager extends ZooKeeperListener {
volatile long last_update; volatile long last_update;
volatile int last_version; volatile int last_version;
volatile ServerName cur_worker_name; volatile ServerName cur_worker_name;
TaskBatch batch; volatile TaskBatch batch;
volatile TerminationStatus status; volatile TerminationStatus status;
volatile int incarnation; volatile int incarnation;
volatile int unforcedResubmits; volatile int unforcedResubmits;
@ -1182,7 +1181,7 @@ public class SplitLogManager extends ZooKeeperListener {
} }
return; return;
} else { } else {
LOG.debug(path + LOG.info(path +
" does not exist. Either was created but deleted behind our" + " does not exist. Either was created but deleted behind our" +
" back by another pending delete OR was deleted" + " back by another pending delete OR was deleted" +
" in earlier retry rounds. zkretries = " + (Long) ctx); " in earlier retry rounds. zkretries = " + (Long) ctx);