Fix the problem that not released of parallel resources.

WeDataSphere · Nov 18, 2024 · 86ce76a · 86ce76a
1 parent b505001
commit 86ce76a
Showing 1 changed file with 9 additions and 3 deletions.
diff --git a/.../com/webank/wedatasphere/exchangis/job/server/execution/subscriber/NewInTaskObserver.java b/.../com/webank/wedatasphere/exchangis/job/server/execution/subscriber/NewInTaskObserver.java
@@ -75,9 +75,15 @@ public int subscribe(List<LaunchableExchangisTask> publishedTasks) throws Exchan
                                 if (parallelRule.incParallel()) {
                                     // check the status of launchedTask
                                     // insert or update launched task, status as TaskStatus.Scheduler
-                                    boolean success =  observerService.subscribe(launchableExchangisTask);
-                                    if (!success){
-                                        parallelRule.decParallel(1);
+                                    boolean success =  false;
+                                    try {
+                                        success = observerService.subscribe(launchableExchangisTask);
+                                    } catch (Exception e){
+                                        throw e;
+                                    } finally {
+                                        if (!success){
+                                            parallelRule.decParallel(1);
+                                        }
                                     }
                                     return success;
                                 }