adapt jdk11 (#204)

apache · Aug 31, 2022 · c8d393b · c8d393b
1 parent 54426de
commit c8d393b
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 10 deletions.
diff --git a/...src/main/java/org/apache/rocketmq/streams/common/checkpoint/CheckPointStorageFactory.java b/...src/main/java/org/apache/rocketmq/streams/common/checkpoint/CheckPointStorageFactory.java
@@ -17,8 +17,6 @@
 
 package org.apache.rocketmq.streams.common.checkpoint;
 
-import java.net.URL;
-import java.net.URLClassLoader;
 import java.util.Iterator;
 import java.util.ServiceLoader;
 import org.apache.commons.logging.Log;
@@ -35,14 +33,6 @@ public class CheckPointStorageFactory {
     private ServiceLoader<ICheckPointStorage> loader;
 
     private CheckPointStorageFactory() {
-        URLClassLoader classLoader = (URLClassLoader) Thread.currentThread().getContextClassLoader();
-        URL[] urls = classLoader.getURLs();
-        for (URL u : urls) {
-            String s = u.toString();
-            if (s.contains("rocketmq-streams")) {
-                logger.debug(String.format("list class : %s", s));
-            }
-        }
         loader = ServiceLoader.load(ICheckPointStorage.class);
     }
 

diff --git a/...q-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/ReflectUtil.java b/...q-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/ReflectUtil.java
@@ -446,6 +446,8 @@ public static void scanFields(Object o, Class clazz, IFieldProcessor fieldProces
                     continue;
                 } else if (Modifier.isNative(field.getModifiers())) {
                     continue;
+                } else if (field.getType().getName().equals(clazz.getName())) {
+                    continue;
                 }
                 fieldProcessor.doProcess(o, field);
             }catch (Exception e){