We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent a29c009 commit 70eae92Copy full SHA for 70eae92
operator-framework-core/src/main/java/io/javaoperatorsdk/operator/Operator.java
@@ -203,7 +203,12 @@ public synchronized void start() {
203
public void stop() throws OperatorException {
204
Duration reconciliationTerminationTimeout =
205
configurationService.reconciliationTerminationTimeout();
206
+
207
if (!started) {
208
+ // Always stop the executor service manager to prevent dangling threads,
209
+ // even if the operator didn't fully start
210
+ configurationService.getExecutorServiceManager().stop(reconciliationTerminationTimeout);
211
212
return;
213
}
214
log.info(
0 commit comments