From f9ad7cab404667aade6fc31561f4b636602fa136 Mon Sep 17 00:00:00 2001 From: Sagar Sumit Date: Mon, 22 Nov 2021 19:17:02 +0530 Subject: [PATCH] [MINOR] Fix instant parsing in HoodieClusteringJob --- .../java/org/apache/hudi/utilities/HoodieClusteringJob.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieClusteringJob.java b/hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieClusteringJob.java index ac8e7e8074fce..3ff3a99d98eae 100644 --- a/hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieClusteringJob.java +++ b/hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieClusteringJob.java @@ -241,7 +241,7 @@ private int doScheduleAndCluster(JavaSparkContext jsc) throws Exception { HoodieTimeline inflightHoodieTimeline = table.getActiveTimeline().filterPendingReplaceTimeline().filterInflights(); if (!inflightHoodieTimeline.empty()) { HoodieInstant inflightClusteringInstant = inflightHoodieTimeline.lastInstant().get(); - Date clusteringStartTime = HoodieActiveTimeline.COMMIT_FORMATTER.parse(inflightClusteringInstant.getTimestamp()); + Date clusteringStartTime = HoodieActiveTimeline.parseInstantTime(inflightClusteringInstant.getTimestamp()); if (clusteringStartTime.getTime() + cfg.maxProcessingTimeMs < System.currentTimeMillis()) { // if there has failed clustering, then we will use the failed clustering instant-time to trigger next clustering action which will rollback and clustering. LOG.info("Found failed clustering instant at : " + inflightClusteringInstant + "; Will rollback the failed clustering and re-trigger again.");