lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[MINOR] Close log scanner after compaction completed (#3294)

Browse Source
This commit is contained in:
Gary Li
2021-07-26 17:39:13 +08:00
committed by GitHub
parent a91296f14a
commit a5638b995b
2 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/table/action/compact/HoodieFlinkMergeOnReadTableCompactor.java
View File

@@ -162,6 +162,7 @@ public class HoodieFlinkMergeOnReadTableCompactor<T extends HoodieRecordPayload>
RuntimeStats runtimeStats = new RuntimeStats(); RuntimeStats runtimeStats = new RuntimeStats();
runtimeStats.setTotalScanTime(scanner.getTotalTimeTakenToReadAndMergeBlocks()); runtimeStats.setTotalScanTime(scanner.getTotalTimeTakenToReadAndMergeBlocks());
s.getStat().setRuntimeStats(runtimeStats); s.getStat().setRuntimeStats(runtimeStats);
scanner.close();
}).collect(toList()); }).collect(toList());
} }

1
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/compact/HoodieSparkMergeOnReadTableCompactor.java
View File

@@ -184,6 +184,7 @@ public class HoodieSparkMergeOnReadTableCompactor<T extends HoodieRecordPayload>
RuntimeStats runtimeStats = new RuntimeStats(); RuntimeStats runtimeStats = new RuntimeStats();
runtimeStats.setTotalScanTime(scanner.getTotalTimeTakenToReadAndMergeBlocks()); runtimeStats.setTotalScanTime(scanner.getTotalTimeTakenToReadAndMergeBlocks());
s.getStat().setRuntimeStats(runtimeStats); s.getStat().setRuntimeStats(runtimeStats);
scanner.close();
}).collect(toList()); }).collect(toList());
} }