From 2d51bc79c7f25a46ab89e1339f01662f07767d06 Mon Sep 17 00:00:00 2001 From: Sivabalan Narayanan Date: Wed, 28 Sep 2022 12:14:24 -0700 Subject: [PATCH] [MINOR] fixing validate async operations to poll completed clean instances (#6814) --- .../hudi/integ/testsuite/dag/nodes/ValidateAsyncOperations.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/dag/nodes/ValidateAsyncOperations.java b/hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/dag/nodes/ValidateAsyncOperations.java index 0835ec97226e4..714f3bf6cac81 100644 --- a/hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/dag/nodes/ValidateAsyncOperations.java +++ b/hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/dag/nodes/ValidateAsyncOperations.java @@ -62,7 +62,7 @@ public void execute(ExecutionContext executionContext, int curItrCount) throws E HoodieTableMetaClient metaClient = HoodieTableMetaClient.builder().setBasePath(executionContext.getHoodieTestSuiteWriter().getCfg().targetBasePath) .setConf(executionContext.getJsc().hadoopConfiguration()).build(); - Option latestCleanInstant = metaClient.getActiveTimeline().filter(instant -> instant.getAction().equals(HoodieTimeline.CLEAN_ACTION)).lastInstant(); + Option latestCleanInstant = metaClient.getActiveTimeline().getCleanerTimeline().filterCompletedInstants().lastInstant(); if (latestCleanInstant.isPresent()) { log.warn("Latest clean commit " + latestCleanInstant.get()); HoodieCleanMetadata cleanMetadata = CleanerUtils.getCleanerMetadata(metaClient, latestCleanInstant.get());