diff --git a/integration-test/common/src/test/java/org/apache/uniffle/test/CoordinatorGrpcTest.java b/integration-test/common/src/test/java/org/apache/uniffle/test/CoordinatorGrpcTest.java index 88a04190f4..fc80acf53e 100644 --- a/integration-test/common/src/test/java/org/apache/uniffle/test/CoordinatorGrpcTest.java +++ b/integration-test/common/src/test/java/org/apache/uniffle/test/CoordinatorGrpcTest.java @@ -326,22 +326,16 @@ public void shuffleServerHeartbeatTest() throws Exception { @Test public void rpcMetricsTest() throws Exception { - double oldValue = - coordinators - .get(0) - .getGrpcMetrics() - .getCounterMap() - .get(CoordinatorGrpcMetrics.HEARTBEAT_METHOD) - .get(); + double oldValue, newValue; CoordinatorTestUtils.waitForRegister(coordinatorClient, 2); - double newValue = + newValue = coordinators .get(0) .getGrpcMetrics() .getCounterMap() .get(CoordinatorGrpcMetrics.HEARTBEAT_METHOD) .get(); - assertTrue(newValue - oldValue > 1); + assertTrue(newValue > 1); String appId = "rpcMetricsTest"; RssGetShuffleAssignmentsRequest request =