|
12 | 12 | */ |
13 | 13 | package io.kubernetes.client.informer.cache; |
14 | 14 |
|
15 | | -import java.io.IOException; |
16 | | -import java.net.ConnectException; |
17 | | -import java.net.HttpURLConnection; |
18 | | -import java.time.Duration; |
19 | | -import java.util.List; |
20 | | -import java.util.Optional; |
21 | | -import java.util.concurrent.atomic.AtomicBoolean; |
22 | | -import java.util.function.BiConsumer; |
23 | | - |
24 | | -import org.slf4j.Logger; |
25 | | -import org.slf4j.LoggerFactory; |
26 | | - |
27 | 15 | import io.kubernetes.client.common.KubernetesListObject; |
28 | 16 | import io.kubernetes.client.common.KubernetesObject; |
29 | 17 | import io.kubernetes.client.informer.EventType; |
|
35 | 23 | import io.kubernetes.client.util.CallGeneratorParams; |
36 | 24 | import io.kubernetes.client.util.Strings; |
37 | 25 | import io.kubernetes.client.util.Watchable; |
| 26 | +import java.io.IOException; |
| 27 | +import java.net.ConnectException; |
| 28 | +import java.net.HttpURLConnection; |
| 29 | +import java.time.Duration; |
| 30 | +import java.util.List; |
| 31 | +import java.util.Optional; |
| 32 | +import java.util.concurrent.atomic.AtomicBoolean; |
| 33 | +import java.util.function.BiConsumer; |
| 34 | +import org.slf4j.Logger; |
| 35 | +import org.slf4j.LoggerFactory; |
38 | 36 |
|
39 | 37 | public class ReflectorRunnable< |
40 | 38 | ApiType extends KubernetesObject, ApiListType extends KubernetesListObject> |
@@ -167,7 +165,6 @@ public void run() { |
167 | 165 | public void stop() { |
168 | 166 | try { |
169 | 167 | isActive.set(false); |
170 | | - closeWatch(); |
171 | 168 | } catch (Throwable t) { |
172 | 169 | this.exceptionHandler.accept(apiTypeClass, t); |
173 | 170 | } |
|
0 commit comments