lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[HUDI-1005] fix NPE in HoodieWriteClient.clean

Browse Source
This commit is contained in:
shenhong
2020-06-08 11:59:09 +08:00
committed by vinoth chandar
parent 6318e943d1
commit 3387b3841f
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
hudi-client/src/main/java/org/apache/hudi/client/HoodieWriteClient.java
View File

@@ -490,7 +490,7 @@ public class HoodieWriteClient<T extends HoodieRecordPayload> extends AbstractHo
LOG.info("Cleaner started"); LOG.info("Cleaner started");
final Timer.Context context = metrics.getCleanCtx(); final Timer.Context context = metrics.getCleanCtx();
HoodieCleanMetadata metadata = HoodieTable.create(config, hadoopConf).clean(jsc, cleanInstantTime); HoodieCleanMetadata metadata = HoodieTable.create(config, hadoopConf).clean(jsc, cleanInstantTime);
if (context != null) { if (context != null && metadata != null) {
long durationMs = metrics.getDurationInMs(context.stop()); long durationMs = metrics.getDurationInMs(context.stop());
metrics.updateCleanMetrics(durationMs, metadata.getTotalFilesDeleted()); metrics.updateCleanMetrics(durationMs, metadata.getTotalFilesDeleted());
LOG.info("Cleaned " + metadata.getTotalFilesDeleted() + " files" LOG.info("Cleaned " + metadata.getTotalFilesDeleted() + " files"