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 2015/09/07 06:51:57 UTC
[2/3] hbase git commit: HBASE-14317 Stuck FSHLog: bad disk
(HDFS-8960) and can't roll WAL
http://git-wip-us.apache.org/repos/asf/hbase/blob/bbafb47f/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/TestLogRolling.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/TestLogRolling.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/TestLogRolling.java
index caf05a4..daca637 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/TestLogRolling.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/TestLogRolling.java
@@ -89,10 +89,6 @@ public class TestLogRolling {
private MiniHBaseCluster cluster;
private static final HBaseTestingUtility TEST_UTIL = new HBaseTestingUtility();
- /**
- * constructor
- * @throws Exception
- */
public TestLogRolling() {
this.server = null;
this.tableName = null;
@@ -527,7 +523,16 @@ public class TestLogRolling {
// flush all regions
for (Region r: server.getOnlineRegionsLocalContext()) {
- r.flush(true);
+ try {
+ r.flush(true);
+ } catch (Exception e) {
+ // This try/catch was added by HBASE-14317. It is needed
+ // because this issue tightened up the semantic such that
+ // a failed append could not be followed by a successful
+ // sync. What is coming out here is a failed sync, a sync
+ // that used to 'pass'.
+ LOG.info(e);
+ }
}
ResultScanner scanner = table.getScanner(new Scan());