diff --git a/hbase-asyncfs/src/test/java/org/apache/hadoop/hbase/io/asyncfs/TestFanOutOneBlockAsyncDFSOutput.java b/hbase-asyncfs/src/test/java/org/apache/hadoop/hbase/io/asyncfs/TestFanOutOneBlockAsyncDFSOutput.java
index 8533d38bae0..abdba33b803 100644
--- a/hbase-asyncfs/src/test/java/org/apache/hadoop/hbase/io/asyncfs/TestFanOutOneBlockAsyncDFSOutput.java
+++ b/hbase-asyncfs/src/test/java/org/apache/hadoop/hbase/io/asyncfs/TestFanOutOneBlockAsyncDFSOutput.java
@@ -220,6 +220,7 @@ public class TestFanOutOneBlockAsyncDFSOutput extends AsyncFSTestBase {
       assertEquals(2, output.getPipeline().length);
     } finally {
       CLUSTER.restartDataNode(dnProp);
+      CLUSTER.triggerBlockReports();
     }
   }
 
@@ -250,6 +251,7 @@ public class TestFanOutOneBlockAsyncDFSOutput extends AsyncFSTestBase {
       assertEquals(1, excludeDatanodeManager.getExcludeDNs().size());
     } finally {
       CLUSTER.restartDataNode(dnProp);
+      CLUSTER.triggerBlockReports();
     }
   }