lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[HUDI-525] lack of insert info in delta_commit inflight

Browse Source 
[HUDI-525] lack of insert info in delta_commit inflight

[HUDI-525] lack of insert info in delta_commit inflight

[HUDI-525] lack of insert info in delta_commit inflight

[HUDI-525] lack of insert info in delta_commit inflight

[HUDI-525] lack of insert info in delta_commit inflight

HUDI-525
This commit is contained in:
liujianhui
2020-04-12 22:11:38 +08:00
committed by n3nash
parent ab11ba43e1
commit d3711a2641
1 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
hudi-client/src/main/java/org/apache/hudi/table/action/commit/BaseCommitActionExecutor.java
View File

@@ -116,6 +116,12 @@ public abstract class BaseCommitActionExecutor<T extends HoodieRecordPayload<T>,
HoodieCommitMetadata metadata = new HoodieCommitMetadata(); HoodieCommitMetadata metadata = new HoodieCommitMetadata();
profile.getPartitionPaths().forEach(path -> { profile.getPartitionPaths().forEach(path -> {
WorkloadStat partitionStat = profile.getWorkloadStat(path.toString()); WorkloadStat partitionStat = profile.getWorkloadStat(path.toString());
HoodieWriteStat insertStat = new HoodieWriteStat();
insertStat.setNumInserts(partitionStat.getNumInserts());
insertStat.setFileId("");
insertStat.setPrevCommit(HoodieWriteStat.NULL_COMMIT);
metadata.addWriteStat(path.toString(), insertStat);
partitionStat.getUpdateLocationToCount().forEach((key, value) -> { partitionStat.getUpdateLocationToCount().forEach((key, value) -> {
HoodieWriteStat writeStat = new HoodieWriteStat(); HoodieWriteStat writeStat = new HoodieWriteStat();
writeStat.setFileId(key); writeStat.setFileId(key);