[rocketmq-streams] branch main updated: adapt jdk11 (#204)

[duhengforever]

This is an automated email from the ASF dual-hosted git repository.

duhengforever pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-streams.git


The following commit(s) were added to refs/heads/main by this push:
     new c8d393b7 adapt jdk11 (#204)
c8d393b7 is described below

commit c8d393b7491693798fd397e0c4267194da0967cb
Author: HuiTong <yibinh...@163.com>
AuthorDate: Wed Aug 31 14:06:49 2022 +0800

    adapt jdk11 (#204)
---
 .../streams/common/checkpoint/CheckPointStorageFactory.java    | 10 ----------
 .../org/apache/rocketmq/streams/common/utils/ReflectUtil.java  |  2 ++
 2 files changed, 2 insertions(+), 10 deletions(-)

diff --git 
a/rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/checkpoint/CheckPointStorageFactory.java
 
b/rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/checkpoint/CheckPointStorageFactory.java
index 91afa326..2bd93a59 100644
--- 
a/rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/checkpoint/CheckPointStorageFactory.java
+++ 
b/rocketmq-streams-commons/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/rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/ReflectUtil.java
 
b/rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/ReflectUtil.java
index 702dca0d..45f7d236 100644
--- 
a/rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/ReflectUtil.java
+++ 
b/rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/ReflectUtil.java
@@ -446,6 +446,8 @@ public class ReflectUtil {
                     continue;
                 } else if (Modifier.isNative(field.getModifiers())) {
                     continue;
+                } else if (field.getType().getName().equals(clazz.getName())) {
+                    continue;
                 }
                 fieldProcessor.doProcess(o, field);
             }catch (Exception e){