Merge pull request kubernetes-client#1611 from yue9944882/chore/rewatch-log-level

k8s-ci-robot · web-flow · commit f716b3835d9b · 2021-03-24T11:36:08.000-07:00
Chore: Reducing rewatch logging verbosity upon normal re-connection
diff --git a/util/src/main/java/io/kubernetes/client/informer/cache/ReflectorRunnable.java b/util/src/main/java/io/kubernetes/client/informer/cache/ReflectorRunnable.java
@@ -223,10 +223,15 @@ private void watchHandler(Watchable<ApiType> watch) {
         continue;
       }
       if (eventType.get() == EventType.ERROR) {
-        String errorMessage =
-            String.format("got ERROR event and its status: %s", item.status.toString());
-        log.error(errorMessage);
-        throw new RuntimeException(errorMessage);
+        if (item.status != null && item.status.getCode() == HttpURLConnection.HTTP_GONE) {
+          log.info("Watch connection expired: {}", item.status.getMessage());
+          return;
+        } else {
+          String errorMessage =
+              String.format("got ERROR event and its status: %s", item.status.toString());
+          log.error(errorMessage);
+          throw new RuntimeException(errorMessage);
+        }
       }
 
       ApiType obj = item.object;
