diff --git a/kubernetes-client/src/main/java/io/fabric8/kubernetes/client/informers/cache/ReflectorWatcher.java b/kubernetes-client/src/main/java/io/fabric8/kubernetes/client/informers/cache/ReflectorWatcher.java index 95521406420..d8184dac8da 100644 --- a/kubernetes-client/src/main/java/io/fabric8/kubernetes/client/informers/cache/ReflectorWatcher.java +++ b/kubernetes-client/src/main/java/io/fabric8/kubernetes/client/informers/cache/ReflectorWatcher.java @@ -45,14 +45,12 @@ public ReflectorWatcher(Store store, AtomicReference lastSyncResource public void eventReceived(Action action, T resource) { if (action == null) { final String errorMessage = String.format("Unrecognized event %s", resource.getMetadata().getName()); - log.error(errorMessage); throw new KubernetesClientException(errorMessage); } - log.debug("Event received {}", action.name()); + log.trace("Event received {}", action.name()); switch (action) { case ERROR: final String errorMessage = String.format("ERROR event for %s", resource.getMetadata().getName()); - log.error(errorMessage); throw new KubernetesClientException(errorMessage); case ADDED: store.add(resource); @@ -65,12 +63,12 @@ public void eventReceived(Action action, T resource) { break; } lastSyncResourceVersion.set(resource.getMetadata().getResourceVersion()); - log.debug("{}#Receiving resourceVersion {}", resource.getKind(), lastSyncResourceVersion.get()); + log.trace("{}#Receiving resourceVersion {}", resource.getKind(), lastSyncResourceVersion.get()); } @Override public void onClose(WatcherException exception) { - log.error("Watch closing"); + log.warn("Watch closing with exception", exception); Optional.ofNullable(exception) .map(e -> { log.debug("Exception received during watch", e); @@ -83,7 +81,7 @@ public void onClose(WatcherException exception) { @Override public void onClose() { - log.info("Watch gracefully closed"); + log.debug("Watch gracefully closed"); onClose.run(); } }