lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

Revert "[HUDI-3043] Revert async cleaner leak commit to unblock CI failure (#4343)" (#4465)

Browse Source 
This reverts commit 7e7ad1558c.
This commit is contained in:
Sivabalan Narayanan
2021-12-29 21:45:09 -05:00
committed by GitHub
parent 504747ecf4
commit 5c0e4ce005
5 changed files with 31 additions and 38 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/client/HoodieFlinkWriteClient.java
View File

@@ -281,7 +281,11 @@ public class HoodieFlinkWriteClient<T extends HoodieRecordPayload> extends
* checkpoint finish.
*/
public void startAsyncCleaning() {
this.asyncCleanerService = AsyncCleanerService.startAsyncCleaningIfEnabled(this);
if (this.asyncCleanerService == null) {
this.asyncCleanerService = AsyncCleanerService.startAsyncCleaningIfEnabled(this);
} else {
this.asyncCleanerService.start(null);
}
}
/**