This is an automated email from the ASF dual-hosted git repository.

chungen0126 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 d18115d1ed4 HDDS-16523. Fix flaky openFileTable assertions in 
TestHSync (#11281)
d18115d1ed4 is described below

commit d18115d1ed49973287766002eb0ae5f2378b07d6
Author: rjgoyln <[email protected]>
AuthorDate: Mon Sep 21 21:57:54 2026 +0800

    HDDS-16523. Fix flaky openFileTable assertions in TestHSync (#11281)
---
 .../src/test/java/org/apache/hadoop/fs/ozone/TestHSync.java           | 4 ++++
 1 file changed, 4 insertions(+)

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 0abae8bfa51..01087c7cfce 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
@@ -492,6 +492,8 @@ public void testHSyncOpenKeyCommitAfterExpiry() throws 
Exception {
         // Create key2 without hsync
         try (FSDataOutputStream os1 = fs.create(key2, true)) {
           os1.write(1);
+          // Wait for double buffer flush to avoid flakiness because RDB 
iterator bypasses table cache
+          cluster.getOzoneManager().awaitDoubleBufferFlush();
           // There should be 2 key in openFileTable
           assertThat(getOpenKeyInfo(BUCKET_LAYOUT))
               .extracting(OmKeyInfo::getKeyName)
@@ -586,6 +588,8 @@ public void testHSyncOpenKeyDeletionWhileDeleteDirectory() 
throws Exception {
       try (FSDataOutputStream os = fs.create(key1, true)) {
         os.write(1);
         os.hsync();
+        // Wait for double buffer flush to avoid flakiness because RDB 
iterator bypasses table cache
+        cluster.getOzoneManager().awaitDoubleBufferFlush();
         // There should be 1 key in openFileTable
         assertThat(getOpenKeyInfo(BUCKET_LAYOUT))
             .extracting(OmKeyInfo::getKeyName)


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to