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)
