This is an automated email from the ASF dual-hosted git repository.
zhangduo pushed a commit to branch branch-2.6
in repository https://gitbox.apache.org/repos/asf/hbase.git
The following commit(s) were added to refs/heads/branch-2.6 by this push:
new 0d0952261a8 HBASE-28190 Add slow sync log rolling test in
TestAsyncLogRolling. (#5583)
0d0952261a8 is described below
commit 0d0952261a8bc2a0ffbe1b6efc918afb5f197d88
Author: Fantasy-Jay <13631435...@163.com>
AuthorDate: Tue Dec 19 11:56:11 2023 +0800
HBASE-28190 Add slow sync log rolling test in TestAsyncLogRolling. (#5583)
Signed-off-by: Duo Zhang
(cherry picked from commit c668cbcb8acc25a059ee102557e02a959cbcada7)
---
.../hbase/regionserver/wal/AbstractFSWAL.java | 4 +
.../hadoop/hbase/regionserver/wal/FSHLog.java | 8 -
.../regionserver/wal/AbstractTestLogRolling.java | 106 +-
.../regionserver/wal/TestAsyncLogRolling.java | 65 ++
.../hadoop/hbase/regionserver/wal/TestFSHLog.java | 12 +-
.../hbase/regionserver/wal/TestLogRolling.java | 234 +
6 files changed, 225 insertions(+), 204 deletions(-)
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 c9ff80f69c6..0beffbd1dd7 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
@@ -1395,6 +1395,10 @@ public abstract class AbstractFSWAL implements WAL {
WALSplitter.split(baseDir, p, archiveDir, fs, conf,
WALFactory.getInstance(conf));
}
+ W getWriter() {
+return this.writer;
+ }
+
private static void usage() {
System.err.println("Usage: AbstractFSWAL ");
System.err.println("Arguments:");
diff --git
a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/FSHLog.java
b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/FSHLog.java
index 6afe2e06794..42f0235f67b 100644
---
a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/FSHLog.java
+++
b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/FSHLog.java
@@ -1208,12 +1208,4 @@ public class FSHLog extends AbstractFSWAL {
}
return new DatanodeInfo[0];
}
-
- Writer getWriter() {
-return this.writer;
- }
-
- void setWriter(Writer writer) {
-this.writer = writer;
- }
}
diff --git
a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/AbstractTestLogRolling.java
b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/AbstractTestLogRolling.java
index 722f5ce5bc2..b06fbb51b74 100644
---
a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/AbstractTestLogRolling.java
+++
b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/AbstractTestLogRolling.java
@@ -20,9 +20,13 @@ package org.apache.hadoop.hbase.regionserver.wal;
import static org.hamcrest.MatcherAssert.assertThat;
import static org.hamcrest.Matchers.greaterThan;
import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertFalse;
import static org.junit.Assert.assertTrue;
import java.io.IOException;
+import java.util.concurrent.Executors;
+import java.util.concurrent.ScheduledExecutorService;
+import java.util.concurrent.atomic.AtomicBoolean;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.hbase.HBaseTestingUtility;
@@ -31,6 +35,7 @@ import org.apache.hadoop.hbase.MiniHBaseCluster;
import org.apache.hadoop.hbase.ServerName;
import org.apache.hadoop.hbase.StartMiniClusterOption;
import org.apache.hadoop.hbase.TableName;
+import org.apache.hadoop.hbase.Waiter;
import org.apache.hadoop.hbase.client.Admin;
import org.apache.hadoop.hbase.client.ColumnFamilyDescriptorBuilder;
import org.apache.hadoop.hbase.client.Get;
@@ -48,8 +53,10 @@ import org.apache.hadoop.hbase.util.Threads;
import org.apache.hadoop.hbase.wal.AbstractFSWALProvider;
import org.apache.hadoop.hbase.wal.WAL;
import org.apache.hadoop.hbase.wal.WALFactory;
+import org.apache.hadoop.hbase.wal.WALProvider;
import org.apache.hadoop.hdfs.MiniDFSCluster;
import org.junit.After;
+import org.junit.AfterClass;
import org.junit.Assert;
import org.junit.Before;
import org.junit.BeforeClass;
@@ -59,6 +66,8 @@ import org.junit.rules.TestName;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+import
org.apache.hbase.thirdparty.com.google.common.util.concurrent.ThreadFactoryBuilder;
+
/**
* Test log deletion as logs are rolled.
*/
@@ -74,6 +83,10 @@ public abstract class AbstractTestLogRolling {
protected static final HBaseTestingUtility TEST_UTIL = new
HBaseTestingUtility();
@Rule
public final TestName name = new TestName();
+ protected static int syncLatencyMillis;
+ pr
