lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[MINOR] Prevent async service from starting twice (#4801)

Browse Source
This commit is contained in:
Raymond Xu
2022-02-14 11:06:31 -08:00
committed by GitHub
parent 0db1e978c6
commit bcfd8efe66
1 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/async/HoodieAsyncService.java
View File

@@ -125,6 +125,10 @@ public abstract class HoodieAsyncService implements Serializable {
* @param onShutdownCallback * @param onShutdownCallback
*/ */
public void start(Function<Boolean, Boolean> onShutdownCallback) { public void start(Function<Boolean, Boolean> onShutdownCallback) {
if (started) {
LOG.warn("The async service already started.");
return;
}
Pair<CompletableFuture, ExecutorService> res = startService(); Pair<CompletableFuture, ExecutorService> res = startService();
future = res.getKey(); future = res.getKey();
executor = res.getValue(); executor = res.getValue();