You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@hudi.apache.org by "liujianhui (Jira)" <ji...@apache.org> on 2020/01/13 04:22:00 UTC

[jira] [Created] (HUDI-525) inserts info miss in delta_commit_inflight meta file

liujianhui created HUDI-525:
-------------------------------

             Summary: inserts info miss in delta_commit_inflight meta file
                 Key: HUDI-525
                 URL: https://issues.apache.org/jira/browse/HUDI-525
             Project: Apache Hudi (incubating)
          Issue Type: Bug
            Reporter: liujianhui


should add  insert info in WorkInfoStat

{code}

private void saveWorkloadProfileMetadataToInflight(WorkloadProfile profile, HoodieTable<T> table, String commitTime)
 throws HoodieCommitException {
 try {
 HoodieCommitMetadata metadata = new HoodieCommitMetadata();
 profile.getPartitionPaths().forEach(path -> {
 WorkloadStat partitionStat = profile.getWorkloadStat(path.toString());
 partitionStat.getUpdateLocationToCount().forEach((key, value) -> {
 HoodieWriteStat writeStat = new HoodieWriteStat();
 writeStat.setFileId(key);
 // TODO : Write baseCommitTime is possible here ?
 writeStat.setPrevCommit(value.getKey());
 writeStat.setNumUpdateWrites(value.getValue());
 metadata.addWriteStat(path.toString(), writeStat);
 });
 });

{code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)