Skip to content

Commit

Permalink
[apache#244][FOLLOWUP] Flaky Test: CoordinatorGrpcTest.rpcMetricsTest.
Browse files Browse the repository at this point in the history
  • Loading branch information
zhengchenyu committed Oct 20, 2023
1 parent 4f56e59 commit 78882bf
Showing 1 changed file with 3 additions and 9 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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 =
Expand Down

0 comments on commit 78882bf

Please sign in to comment.