Index: src/main/java/org/apache/hadoop/hbase/regionserver/wal/HLogSplitter.java =================================================================== --- src/main/java/org/apache/hadoop/hbase/regionserver/wal/HLogSplitter.java (revision 1221536) +++ src/main/java/org/apache/hadoop/hbase/regionserver/wal/HLogSplitter.java (working copy) @@ -364,8 +364,6 @@ Object BAD_WRITER = new Object(); - boolean progress_failed = false; - boolean skipErrors = conf.getBoolean("hbase.hlog.split.skip.errors", HLog.SPLIT_SKIP_ERRORS_DEFAULT); int interval = conf.getInt("hbase.splitlog.report.interval.loglines", 1024); @@ -426,7 +424,6 @@ last_report_at = t; if (reporter != null && reporter.progress() == false) { status.markComplete("Failed: reporter.progress asked us to terminate"); - progress_failed = true; return false; } } @@ -445,9 +442,8 @@ long t1 = EnvironmentEdgeManager.currentTimeMillis(); if ((t1 - last_report_at) > period) { last_report_at = t; - if ((progress_failed == false) && (reporter != null) && - (reporter.progress() == false)) { - progress_failed = true; + if ((reporter != null) && (reporter.progress() == false)) { + return false; } } if (o == BAD_WRITER) {