Skip to content

Commit 66cab9e

Browse files
committed
[ML] Fix submit after shutdown in process worker service (elastic#83645)
Fix submit after shutdown
1 parent a839b3a commit 66cab9e

File tree

2 files changed

+7
-0
lines changed

2 files changed

+7
-0
lines changed

docs/changelog/83645.yaml

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,6 @@
1+
pr: 83645
2+
summary: Fix submit after shutdown in process worker service
3+
area: Machine Learning
4+
type: bug
5+
issues:
6+
- 83633

x-pack/plugin/ml/src/main/java/org/elasticsearch/xpack/ml/job/process/ProcessWorkerExecutorService.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -95,6 +95,7 @@ public synchronized void execute(Runnable command) {
9595
EsRejectedExecutionException rejected = new EsRejectedExecutionException(processName + " worker service has shutdown", true);
9696
if (command instanceof AbstractRunnable runnable) {
9797
runnable.onRejection(rejected);
98+
return;
9899
} else {
99100
throw rejected;
100101
}

0 commit comments

Comments
 (0)