From 0b97ae540da58834ad0c2f52da483d33f7ca16fb Mon Sep 17 00:00:00 2001
From: xicm <xicm000@gmail.com>
Date: Wed, 9 Mar 2022 10:25:42 +0800
Subject: [PATCH] HBASE-26815: trigger BlockReports in MiniDFSCluster after
 restarting datanode

---
 .../hbase/io/asyncfs/TestFanOutOneBlockAsyncDFSOutput.java      | 2 ++
 1 file changed, 2 insertions(+)

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 8533d38bae09..abdba33b8033 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 void testConnectToDatanodeFailed()
       assertEquals(2, output.getPipeline().length);
     } finally {
       CLUSTER.restartDataNode(dnProp);
+      CLUSTER.triggerBlockReports();
     }
   }
 
@@ -250,6 +251,7 @@ public void testExcludeFailedConnectToDatanode()
       assertEquals(1, excludeDatanodeManager.getExcludeDNs().size());
     } finally {
       CLUSTER.restartDataNode(dnProp);
+      CLUSTER.triggerBlockReports();
     }
   }