From 0e596bbf2f6bfb18848e0bb5bd94064269dab483 Mon Sep 17 00:00:00 2001 From: yue9944882 <291271447@qq.com> Date: Wed, 24 Mar 2021 14:13:07 +0800 Subject: [PATCH] reducing rewatch logging verbosity upon normal re-connection --- .../client/informer/cache/ReflectorRunnable.java | 13 +++++++++---- 1 file changed, 9 insertions(+), 4 deletions(-) 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 index b39d49e2b5..7fc167bdaa 100644 --- 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 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;