Skip to content

Commit 76697d4

Browse files
nsivabalanyuzhaojing
authored andcommitted
[MINOR] fixing validate async operations to poll completed clean instances (apache#6814)
1 parent 3985a5d commit 76697d4

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/dag/nodes/ValidateAsyncOperations.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,7 @@ public void execute(ExecutionContext executionContext, int curItrCount) throws E
6262

6363
HoodieTableMetaClient metaClient = HoodieTableMetaClient.builder().setBasePath(executionContext.getHoodieTestSuiteWriter().getCfg().targetBasePath)
6464
.setConf(executionContext.getJsc().hadoopConfiguration()).build();
65-
Option<HoodieInstant> latestCleanInstant = metaClient.getActiveTimeline().filter(instant -> instant.getAction().equals(HoodieTimeline.CLEAN_ACTION)).lastInstant();
65+
Option<HoodieInstant> latestCleanInstant = metaClient.getActiveTimeline().getCleanerTimeline().filterCompletedInstants().lastInstant();
6666
if (latestCleanInstant.isPresent()) {
6767
log.warn("Latest clean commit " + latestCleanInstant.get());
6868
HoodieCleanMetadata cleanMetadata = CleanerUtils.getCleanerMetadata(metaClient, latestCleanInstant.get());

0 commit comments

Comments
 (0)