Skip to content

Commit 430b1af

Browse files
committed
fixes on rebase from next
1 parent 0be2471 commit 430b1af

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/config/ExecutorServiceManager.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -138,7 +138,8 @@ private void doStop(Duration gracefulShutdownTimeout) {
138138
var parallelExec = Executors.newFixedThreadPool(3);
139139
log.debug("Closing executor");
140140
parallelExec.invokeAll(List.of(shutdown(executor, gracefulShutdownTimeout),
141-
shutdown(workflowExecutor, gracefulShutdownTimeout),shutdown(cachingExecutorService,gracefulShutdownTimeout)));
141+
shutdown(workflowExecutor, gracefulShutdownTimeout),
142+
shutdown(cachingExecutorService, gracefulShutdownTimeout)));
142143
parallelExec.shutdownNow();
143144
} catch (InterruptedException e) {
144145
log.debug("Exception closing executor: {}", e.getLocalizedMessage());

0 commit comments

Comments
 (0)