You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by co...@apache.org on 2022/05/24 07:33:27 UTC
[hudi] branch master updated: [HUDI-2473] Fixing compaction write operation in commit metadata (#5203)
This is an automated email from the ASF dual-hosted git repository.
codope pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
The following commit(s) were added to refs/heads/master by this push:
new c05ebf2417 [HUDI-2473] Fixing compaction write operation in commit metadata (#5203)
c05ebf2417 is described below
commit c05ebf2417f4b170c396dfb60c738ca55bd52309
Author: Sivabalan Narayanan <n....@gmail.com>
AuthorDate: Tue May 24 03:33:21 2022 -0400
[HUDI-2473] Fixing compaction write operation in commit metadata (#5203)
---
.../apache/hudi/table/action/compact/RunCompactionActionExecutor.java | 2 ++
1 file changed, 2 insertions(+)
diff --git a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/compact/RunCompactionActionExecutor.java b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/compact/RunCompactionActionExecutor.java
index 5c184e77df..fc4ae986e6 100644
--- a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/compact/RunCompactionActionExecutor.java
+++ b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/compact/RunCompactionActionExecutor.java
@@ -27,6 +27,7 @@ import org.apache.hudi.common.model.HoodieKey;
import org.apache.hudi.common.model.HoodieRecord;
import org.apache.hudi.common.model.HoodieRecordPayload;
import org.apache.hudi.common.model.HoodieWriteStat;
+import org.apache.hudi.common.model.WriteOperationType;
import org.apache.hudi.common.table.timeline.HoodieTimeline;
import org.apache.hudi.common.util.CompactionUtils;
import org.apache.hudi.common.util.Option;
@@ -99,6 +100,7 @@ public class RunCompactionActionExecutor<T extends HoodieRecordPayload> extends
metadata.addMetadata(SerDeHelper.LATEST_SCHEMA, schemaPair.getLeft().get());
metadata.addMetadata(HoodieCommitMetadata.SCHEMA_KEY, schemaPair.getRight().get());
}
+ metadata.setOperationType(WriteOperationType.COMPACT);
compactionMetadata.setWriteStatuses(statuses);
compactionMetadata.setCommitted(false);
compactionMetadata.setCommitMetadata(Option.of(metadata));