diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.java index 2c0a656049c1..18a4a98c81df 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.java @@ -630,12 +630,8 @@ public Path getCurrentFileName() { * retrieve the next path to use for writing. Increments the internal filenum. */ private Path getNewPath() throws IOException { - this.filenum.set(EnvironmentEdgeManager.currentTime()); + this.filenum.set(Math.max(getFilenum() + 1, EnvironmentEdgeManager.currentTime())); Path newPath = getCurrentFileName(); - while (fs.exists(newPath)) { - this.filenum.incrementAndGet(); - newPath = getCurrentFileName(); - } return newPath; } diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/quotas/TestClusterScopeQuotaThrottle.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/quotas/TestClusterScopeQuotaThrottle.java index fcc023aabea4..8537d9001a7a 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/quotas/TestClusterScopeQuotaThrottle.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/quotas/TestClusterScopeQuotaThrottle.java @@ -43,11 +43,9 @@ import org.junit.AfterClass; import org.junit.BeforeClass; import org.junit.ClassRule; -import org.junit.Ignore; import org.junit.Test; import org.junit.experimental.categories.Category; -@Ignore // disable for now, see HBASE-27045 @Category({ RegionServerTests.class, LargeTests.class }) public class TestClusterScopeQuotaThrottle { diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/quotas/TestQuotaThrottle.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/quotas/TestQuotaThrottle.java index 9dc003cfa274..fdb219fe86cf 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/quotas/TestQuotaThrottle.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/quotas/TestQuotaThrottle.java @@ -44,13 +44,11 @@ import org.junit.AfterClass; import org.junit.BeforeClass; import org.junit.ClassRule; -import org.junit.Ignore; import org.junit.Test; import org.junit.experimental.categories.Category; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -@Ignore // Disabled because flakey. Fails ~30% on a resource constrained GCE though not on Apache. @Category({ RegionServerTests.class, MediumTests.class }) public class TestQuotaThrottle {