bugfix: properly handling non-410 ApiExcetion in the reflector

Author: yue9944882

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

@@ -160,6 +160,8 @@ public void run() {
             "ResourceVersion {} expired, will retry w/o resourceVersion at the next time",
             getRelistResourceVersion());
         isLastSyncResourceVersionUnavailable = true;
+      } else {
+        this.exceptionHandler.accept(apiTypeClass, e);
       }
     } catch (Throwable t) {
       this.exceptionHandler.accept(apiTypeClass, t);

util/src/test/java/io/kubernetes/client/informer/cache/ReflectorRunnableTest.java

@@ -116,7 +116,7 @@ public Watchable<V1Pod> watch(CallGeneratorParams params) throws ApiException {
   }
 
   @Test
-  public void testReflectorRunnableCaptureListException() throws ApiException {
+  public void testReflectorRunnableCaptureListRuntimeException() throws ApiException {
     RuntimeException expectedException = new RuntimeException("noxu");
     AtomicReference<Throwable> actualException = new AtomicReference<>();
     when(listerWatcher.list(any())).thenThrow(expectedException);
@@ -141,6 +141,61 @@ public void testReflectorRunnableCaptureListException() throws ApiException {
     }
   }
 
+  @Test
+  public void testReflectorRunnableShouldPardonList410ApiException() throws ApiException {
+    ApiException expectedException = new ApiException(410, "noxu");
+    AtomicReference<Throwable> actualException = new AtomicReference<>();
+    when(listerWatcher.list(any())).thenThrow(expectedException);
+    ReflectorRunnable<V1Pod, V1PodList> reflectorRunnable =
+        new ReflectorRunnable<>(
+            V1Pod.class,
+            listerWatcher,
+            deltaFIFO,
+            (apiType, t) -> {
+              actualException.set(t);
+            });
+    try {
+      Thread thread = new Thread(reflectorRunnable::run);
+      thread.setDaemon(true);
+      thread.start();
+      Awaitility.await()
+          .atMost(Duration.ofSeconds(1))
+          .pollInterval(Duration.ofMillis(100))
+          .until(
+              () -> {
+                return reflectorRunnable.isLastSyncResourceVersionUnavailable();
+              });
+    } finally {
+      reflectorRunnable.stop();
+    }
+  }
+
+  @Test
+  public void testReflectorRunnableShouldCaptureListNon410ApiException() throws ApiException {
+    ApiException expectedException = new ApiException(403, "noxu");
+    AtomicReference<Throwable> actualException = new AtomicReference<>();
+    when(listerWatcher.list(any())).thenThrow(expectedException);
+    ReflectorRunnable<V1Pod, V1PodList> reflectorRunnable =
+        new ReflectorRunnable<>(
+            V1Pod.class,
+            listerWatcher,
+            deltaFIFO,
+            (apiType, t) -> {
+              actualException.set(t);
+            });
+    try {
+      Thread thread = new Thread(reflectorRunnable::run);
+      thread.setDaemon(true);
+      thread.start();
+      Awaitility.await()
+          .atMost(Duration.ofSeconds(1))
+          .pollInterval(Duration.ofMillis(100))
+          .untilAtomic(actualException, new IsEqual<>(expectedException));
+    } finally {
+      reflectorRunnable.stop();
+    }
+  }
+
   @Test
   public void testReflectorRunnableCaptureWatchException() throws ApiException {
     RuntimeException expectedException = new RuntimeException("noxu");