diff --git a/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/scm/node/TestSCMNodeMetrics.java b/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/scm/node/TestSCMNodeMetrics.java index 3a8f9f0d7b..65a6357de9 100644 --- a/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/scm/node/TestSCMNodeMetrics.java +++ b/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/scm/node/TestSCMNodeMetrics.java @@ -101,9 +101,9 @@ public void testNodeReportProcessing() throws InterruptedException { NodeReportProto nodeReport = NodeReportProto.newBuilder() .addStorageReport(storageReport).build(); datanode.getDatanodeStateMachine().getContext().addReport(nodeReport); - datanode.getDatanodeStateMachine().triggerHeartbeat(); - // Give some time so that SCM receives and processes the heartbeat. - Thread.sleep(100L); + cluster.getStorageContainerManager().getScmNodeManager() + .processNodeReport(datanode.getDatanodeDetails(), nodeReport); + assertCounter("NumNodeReportProcessed", nrProcessed + 1, getMetrics(SCMNodeMetrics.class.getSimpleName())); }