From b5d4da79586192f17c0db458c1d4fcdbb334c3e2 Mon Sep 17 00:00:00 2001 From: Alex Filipchik Date: Tue, 27 Aug 2019 15:31:04 -0700 Subject: [PATCH] Addressing comments --- .../java/org/apache/hudi/common/util/CompactionUtils.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/hudi-common/src/main/java/org/apache/hudi/common/util/CompactionUtils.java b/hudi-common/src/main/java/org/apache/hudi/common/util/CompactionUtils.java index 0588606fe..8a2aa23f9 100644 --- a/hudi-common/src/main/java/org/apache/hudi/common/util/CompactionUtils.java +++ b/hudi-common/src/main/java/org/apache/hudi/common/util/CompactionUtils.java @@ -151,14 +151,15 @@ public class CompactionUtils { return getPendingCompactionOperations(instantPlanPair.getKey(), instantPlanPair.getValue()); }).forEach(pair -> { // Defensive check to ensure a single-fileId does not have more than one pending compaction with different - // params. If we find a full dub we assume it is caused by eventual nature of the move operation on some DFSs. + // file slices. If we find a full duplicate we assume it is caused by eventual nature of the move operation + // on some DFSs. if (fgIdToPendingCompactionWithInstantMap.containsKey(pair.getKey())) { HoodieCompactionOperation operation = pair.getValue().getValue(); HoodieCompactionOperation anotherOperation = fgIdToPendingCompactionWithInstantMap.get(pair.getKey()).getValue(); if (!operation.equals(anotherOperation)) { - String msg = "Hoodie File Id (" + pair.getKey() + ") has more thant 1 pending compactions. Instants: " + String msg = "Hudi File Id (" + pair.getKey() + ") has more than 1 pending compactions. Instants: " + pair.getValue() + ", " + fgIdToPendingCompactionWithInstantMap.get(pair.getKey()); throw new IllegalStateException(msg); }