From 9293d6af2c8591b6042bd8ee8883577f394c7489 Mon Sep 17 00:00:00 2001 From: xicm <36392121+xicm@users.noreply.github.com> Date: Thu, 10 Mar 2022 16:06:12 +0800 Subject: [PATCH] HBASE-26815 TestFanOutOneBlockAsyncDFSOutput is flakey (#4186) Trigger BlockReports in MiniDFSCluster after restarting datanode Signed-off-by: Duo Zhang --- .../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 3b992a853edf..d363282921c9 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 @@ -217,6 +217,7 @@ public void testConnectToDatanodeFailed() assertEquals(2, output.getPipeline().length); } finally { CLUSTER.restartDataNode(dnProp); + CLUSTER.triggerBlockReports(); } } @@ -247,6 +248,7 @@ public void testExcludeFailedConnectToDatanode() assertEquals(1, excludeDatanodeManager.getExcludeDNs().size()); } finally { CLUSTER.restartDataNode(dnProp); + CLUSTER.triggerBlockReports(); } }