This is an automated email from the ASF dual-hosted git repository.
szetszwo pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ozone.git
The following commit(s) were added to refs/heads/master by this push:
new 307c79253d HDDS-8146. TestHSync is no longer flaky. (#4690)
307c79253d is described below
commit 307c79253d78c6b9523ee781603c04da2d930c34
Author: Tsz-Wo Nicholas Sze <[email protected]>
AuthorDate: Tue May 9 13:59:35 2023 -0700
HDDS-8146. TestHSync is no longer flaky. (#4690)
---
.../src/test/java/org/apache/hadoop/fs/ozone/TestHSync.java | 7 ++-----
1 file changed, 2 insertions(+), 5 deletions(-)
diff --git
a/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/fs/ozone/TestHSync.java
b/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/fs/ozone/TestHSync.java
index 5d973dfd1b..8cd2809c3b 100644
---
a/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/fs/ozone/TestHSync.java
+++
b/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/fs/ozone/TestHSync.java
@@ -54,7 +54,6 @@ import org.apache.hadoop.ozone.client.io.OzoneOutputStream;
import org.apache.hadoop.ozone.om.helpers.BucketLayout;
import org.apache.hadoop.util.Time;
-import org.apache.ozone.test.tag.Flaky;
import org.junit.jupiter.api.AfterAll;
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.BeforeAll;
@@ -129,7 +128,6 @@ public class TestHSync {
}
@Test
- @Flaky("HDDS-8024")
public void testO3fsHSync() throws Exception {
// Set the fs.defaultFS
final String rootPath = String.format("%s://%s.%s/",
@@ -145,7 +143,6 @@ public class TestHSync {
}
@Test
- @Flaky("HDDS-8024")
public void testOfsHSync() throws Exception {
// Set the fs.defaultFS
final String rootPath = String.format("%s://%s/",
@@ -231,7 +228,7 @@ public class TestHSync {
assertEquals(data.length, offset);
}
- private void runConcurrentWriteHSync(FileSystem fs, Path file,
+ private void runConcurrentWriteHSync(Path file,
final FSDataOutputStream out, int initialDataSize)
throws InterruptedException, IOException {
final byte[] data = new byte[initialDataSize];
@@ -298,7 +295,7 @@ public class TestHSync {
try (FSDataOutputStream out =
fs.create(file, true)) {
int initialDataSize = 1 << i;
- runConcurrentWriteHSync(fs, file, out, initialDataSize);
+ runConcurrentWriteHSync(file, out, initialDataSize);
}
fs.delete(file, false);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
