diff --git a/util/src/main/java/io/kubernetes/client/informer/cache/Controller.java b/util/src/main/java/io/kubernetes/client/informer/cache/Controller.java index b950b1dd34..602cd52e92 100644 --- a/util/src/main/java/io/kubernetes/client/informer/cache/Controller.java +++ b/util/src/main/java/io/kubernetes/client/informer/cache/Controller.java @@ -158,8 +158,8 @@ public void stop() { reflectorFuture.cancel(true); } } - reflectExecutor.shutdown(); - resyncExecutor.shutdown(); + reflectExecutor.shutdownNow(); + resyncExecutor.shutdownNow(); } /** returns true if the queue has been resycned */