ensure watch connection closed

Author: yue9944882

util/src/main/java/io/kubernetes/client/informer/cache/ReflectorRunnable.java

@@ -9,6 +9,7 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import java.io.IOException;
 import java.lang.reflect.Method;
 import java.net.ConnectException;
 import java.util.ArrayList;
@@ -100,6 +101,10 @@ public void run() {
                     }
                     log.error("ReflectRunnable#watch failed as {} unexpected", t.getMessage(), t);
                     return;
+                } finally {
+                    if (watch != null) {
+                        watch.close();
+                    }
                 }
             }
         } catch (Throwable t) {
@@ -124,7 +129,7 @@ public String getLastSyncResourceVersion() {
         return lastSyncResourceVersion;
     }
 
-    private void watchHandler(io.kubernetes.client.util.Watch<T> watch) {
+    private void watchHandler(io.kubernetes.client.util.Watch<T> watch) throws IOException {
         while (watch.hasNext()) {
             io.kubernetes.client.util.Watch.Response<T> item = watch.next();