HDFS-15378. TestReconstructStripedFile#testErasureCodingWorkerXmitsWeight is failing on trunk. Contributed by hemanthboyina.

ayushtkn · ayushtkn · commit 8db38c98a6c6 · 2020-06-27T19:13:01.000+05:30
diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/TestReconstructStripedFile.java b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/TestReconstructStripedFile.java
@@ -571,7 +571,8 @@ public void stripedBlockReconstruction() throws IOException {
       DataNodeFaultInjector.set(oldInjector);
       for (final DataNode curDn : cluster.getDataNodes()) {
         GenericTestUtils.waitFor(() -> curDn.getXceiverCount() <= 1, 10, 60000);
-        assertEquals(0, curDn.getXmitsInProgress());
+        GenericTestUtils.waitFor(() -> curDn.getXmitsInProgress() == 0, 10,
+            2500);
       }
     }
   }

Original file line number	Diff line number	Diff line change
`@@ -571,7 +571,8 @@ public void stripedBlockReconstruction() throws IOException {`
`571`	`571`	`DataNodeFaultInjector.set(oldInjector);`
`572`	`572`	`for (final DataNode curDn : cluster.getDataNodes()) {`
`573`	`573`	`GenericTestUtils.waitFor(() -> curDn.getXceiverCount() <= 1, 10, 60000);`
`574`		`- assertEquals(0, curDn.getXmitsInProgress());`
	`574`	`+ GenericTestUtils.waitFor(() -> curDn.getXmitsInProgress() == 0, 10,`
	`575`	`+ 2500);`
`575`	`576`	`}`
`576`	`577`	`}`
`577`	`578`	`}`