explicit scheduled executor service

Signed-off-by: Attila Mészáros <a_meszaros@apple.com>

Author: csviri

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

@@ -40,7 +40,8 @@ public class ExecutorServiceManager {
   private static final Logger log = LoggerFactory.getLogger(ExecutorServiceManager.class);
   private ExecutorService executor;
   private ExecutorService workflowExecutor;
-  private ScheduledExecutorService cachingExecutorService;
+  private ExecutorService cachingExecutorService;
+  private ScheduledExecutorService scheduledExecutorService;
   private boolean started;
   private ConfigurationService configurationService;
 
@@ -123,14 +124,19 @@ private synchronized void lazyInitWorkflowExecutorService() {
     }
   }
 
-  public ScheduledExecutorService cachingExecutorService() {
+  public ExecutorService cachingExecutorService() {
     return cachingExecutorService;
   }
 
+  public ScheduledExecutorService scheduledExecutorService() {
+    return scheduledExecutorService;
+  }
+
   public void start(ConfigurationService configurationService) {
     if (!started) {
       this.configurationService = configurationService; // used to lazy init workflow executor
-      this.cachingExecutorService = Executors.newScheduledThreadPool(0);
+      this.cachingExecutorService = Executors.newCachedThreadPool();
+      this.scheduledExecutorService = Executors.newScheduledThreadPool(0);
       this.executor = new InstrumentedExecutorService(configurationService.getExecutorService());
       started = true;
     }

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/informer/ManagedInformerEventSource.java

@@ -160,7 +160,7 @@ public synchronized void start() {
             controllerConfiguration
                 .getConfigurationService()
                 .getExecutorServiceManager()
-                .cachingExecutorService(),
+                .scheduledExecutorService(),
             this);
     this.cache = new InformerManager<>(client, configuration, this);
     cache.setControllerConfiguration(controllerConfiguration);

test.sh

@@ -0,0 +1,17 @@
+#
+# Copyright Java Operator SDK Authors
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#         http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+
+mci -Dlicense.skip jib:dockerBuild && kind load docker-image leader-election-operator:latest