fixes unit-test CI failure

yue9944882 · yue9944882 · commit 2e339ece4d66 · 2020-04-10T11:28:59.000+08:00
diff --git a/spring/src/main/java/io/kubernetes/client/spring/extended/controller/KubernetesReconcilerProcessor.java b/spring/src/main/java/io/kubernetes/client/spring/extended/controller/KubernetesReconcilerProcessor.java
@@ -120,7 +120,7 @@ private Map<Class, AddFilterAdaptor> getAddFilters(
     for (KubernetesReconcilerWatch watch : watches.value()) {
       for (Method method : reconciler.getClass().getMethods()) {
         AddWatchEventFilter annotation = method.getAnnotation(AddWatchEventFilter.class);
-        if (watch.apiTypeClass().equals(annotation.apiTypeClass())) {
+        if (annotation != null && watch.apiTypeClass().equals(annotation.apiTypeClass())) {
           if (filters.containsKey(watch.apiTypeClass())) {
             log.warn(
                 "Duplicated watch ADD event filter upon apiType {}", annotation.apiTypeClass());
@@ -146,7 +146,7 @@ private Map<Class, UpdateFilterAdaptor> getUpdateFilters(
     for (KubernetesReconcilerWatch watch : watches.value()) {
       for (Method method : reconciler.getClass().getMethods()) {
         UpdateWatchEventFilter annotation = method.getAnnotation(UpdateWatchEventFilter.class);
-        if (watch.apiTypeClass().equals(annotation.apiTypeClass())) {
+        if (annotation != null && watch.apiTypeClass().equals(annotation.apiTypeClass())) {
           if (filters.containsKey(watch.apiTypeClass())) {
             log.warn(
                 "Duplicated watch UPDATE event filter upon apiType {}", annotation.apiTypeClass());
@@ -173,7 +173,7 @@ private Map<Class, DeleteFilterAdaptor> getDeleteFilters(
     for (KubernetesReconcilerWatch watch : watches.value()) {
       for (Method method : reconciler.getClass().getMethods()) {
         DeleteWatchEventFilter annotation = method.getAnnotation(DeleteWatchEventFilter.class);
-        if (watch.apiTypeClass().equals(annotation.apiTypeClass())) {
+        if (annotation != null && watch.apiTypeClass().equals(annotation.apiTypeClass())) {
           if (filters.containsKey(watch.apiTypeClass())) {
             log.warn(
                 "Duplicated watch DELETE event filter upon apiType {}", annotation.apiTypeClass());
