We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent a0a3f4d commit 1ae9bddCopy full SHA for 1ae9bdd
extended/src/main/java/io/kubernetes/client/extended/controller/DefaultController.java
@@ -105,7 +105,11 @@ public void run() {
105
workerThreadPool.scheduleWithFixedDelay(
106
() -> {
107
log.debug("Starting controller {} worker {}..", this.name, workerIndex);
108
- this.worker();
+ try {
109
+ this.worker();
110
+ } catch (Throwable t) {
111
+ log.error("Unexpected controller loop abortion", t);
112
+ }
113
latch.countDown();
114
log.debug("Exiting controller {} worker {}..", this.name, workerIndex);
115
},
0 commit comments