From 45eaf7573af4c9420bf53edbe481cd5a92920b61 Mon Sep 17 00:00:00 2001 From: Sourav Maji Date: Thu, 26 Sep 2024 09:46:08 -0700 Subject: [PATCH] [test] Added router metadata refresh in DVC tests --- .../com/linkedin/venice/endToEnd/DaVinciClientDiskFullTest.java | 2 +- .../linkedin/venice/endToEnd/DaVinciClientMemoryLimitTest.java | 1 + 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/internal/venice-test-common/src/integrationTest/java/com/linkedin/venice/endToEnd/DaVinciClientDiskFullTest.java b/internal/venice-test-common/src/integrationTest/java/com/linkedin/venice/endToEnd/DaVinciClientDiskFullTest.java index c7a7a32176..6487a9747b 100644 --- a/internal/venice-test-common/src/integrationTest/java/com/linkedin/venice/endToEnd/DaVinciClientDiskFullTest.java +++ b/internal/venice-test-common/src/integrationTest/java/com/linkedin/venice/endToEnd/DaVinciClientDiskFullTest.java @@ -219,7 +219,7 @@ public void testDaVinciDiskFullFailure(boolean useDaVinciSpecificExecutionStatus // Do a VPJ push runVPJ(vpjProperties, 1, controllerClient); - + venice.refreshAllRouterMetaData(); // Verify some records (note, record 1 have been pushed) TestUtils.waitForNonDeterministicAssertion(10, TimeUnit.SECONDS, true, () -> { try { diff --git a/internal/venice-test-common/src/integrationTest/java/com/linkedin/venice/endToEnd/DaVinciClientMemoryLimitTest.java b/internal/venice-test-common/src/integrationTest/java/com/linkedin/venice/endToEnd/DaVinciClientMemoryLimitTest.java index b8ab2c13ef..b2ebb270c2 100644 --- a/internal/venice-test-common/src/integrationTest/java/com/linkedin/venice/endToEnd/DaVinciClientMemoryLimitTest.java +++ b/internal/venice-test-common/src/integrationTest/java/com/linkedin/venice/endToEnd/DaVinciClientMemoryLimitTest.java @@ -167,6 +167,7 @@ public void testDaVinciMemoryLimitShouldFailLargeDataPush( // Do an VPJ push runVPJ(vpjProperties, 1, controllerClient); + venice.refreshAllRouterMetaData(); // Verify some records (note, records 1-100 have been pushed) TestUtils.waitForNonDeterministicAssertion(10, TimeUnit.SECONDS, true, () -> {