(inlong) branch master updated: [INLONG-11905][SDK] TransformSDK calls the org.reflections library APIs ​​according to version 0.9.12, not version 0.10.2 (#11906)

[luchunliang]

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

luchunliang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new 2ebb00c246 [INLONG-11905][SDK] TransformSDK calls the org.reflections 
library APIs ​​according to version 0.9.12, not version 0.10.2 (#11906)
2ebb00c246 is described below

commit 2ebb00c246359eb8b1675cedaa60b0184609ca11
Author: ChunLiang Lu <luchunli...@apache.org>
AuthorDate: Thu Jun 26 19:34:13 2025 +0800

    [INLONG-11905][SDK] TransformSDK calls the org.reflections library APIs 
​​according to version 0.9.12, not version 0.10.2 (#11906)
---
 .../inlong/sdk/transform/process/function/FunctionTools.java       | 7 +++++--
 .../inlong/sdk/transform/process/operator/OperatorTools.java       | 7 +++++--
 .../apache/inlong/sdk/transform/process/parser/ParserTools.java    | 7 +++++--
 3 files changed, 15 insertions(+), 6 deletions(-)

diff --git 
a/inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/FunctionTools.java
 
b/inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/FunctionTools.java
index 8cf1d51e2b..c7676c4592 100644
--- 
a/inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/FunctionTools.java
+++ 
b/inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/FunctionTools.java
@@ -27,7 +27,8 @@ import net.sf.jsqlparser.expression.Function;
 import org.apache.commons.lang.ArrayUtils;
 import org.apache.commons.lang.StringUtils;
 import org.reflections.Reflections;
-import org.reflections.scanners.Scanners;
+import org.reflections.scanners.SubTypesScanner;
+import org.reflections.scanners.TypeAnnotationsScanner;
 
 import java.lang.reflect.Constructor;
 import java.util.Collection;
@@ -48,7 +49,9 @@ public class FunctionTools {
     }
 
     private static void init() {
-        Reflections reflections = new Reflections(FUNCTION_PATH, 
Scanners.TypesAnnotated);
+        Reflections reflections = new Reflections(FUNCTION_PATH,
+                new TypeAnnotationsScanner(),
+                new SubTypesScanner());
         Set<Class<?>> clazzSet = 
reflections.getTypesAnnotatedWith(TransformFunction.class);
         for (Class<?> clazz : clazzSet) {
             TransformFunction annotation = 
clazz.getAnnotation(TransformFunction.class);
diff --git 
a/inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/operator/OperatorTools.java
 
b/inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/operator/OperatorTools.java
index 0f273cd1eb..cd71d7a3ff 100644
--- 
a/inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/operator/OperatorTools.java
+++ 
b/inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/operator/OperatorTools.java
@@ -28,7 +28,8 @@ import net.sf.jsqlparser.expression.Expression;
 import net.sf.jsqlparser.expression.Function;
 import org.apache.commons.lang.ObjectUtils;
 import org.reflections.Reflections;
-import org.reflections.scanners.Scanners;
+import org.reflections.scanners.SubTypesScanner;
+import org.reflections.scanners.TypeAnnotationsScanner;
 
 import java.lang.reflect.Constructor;
 import java.math.BigDecimal;
@@ -58,7 +59,9 @@ public class OperatorTools {
     }
 
     private static void init() {
-        Reflections reflections = new Reflections(OPERATOR_PATH, 
Scanners.TypesAnnotated);
+        Reflections reflections = new Reflections(OPERATOR_PATH,
+                new TypeAnnotationsScanner(),
+                new SubTypesScanner());
         Set<Class<?>> clazzSet = 
reflections.getTypesAnnotatedWith(TransformOperator.class);
         for (Class<?> clazz : clazzSet) {
             if (ExpressionOperator.class.isAssignableFrom(clazz)) {
diff --git 
a/inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/parser/ParserTools.java
 
b/inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/parser/ParserTools.java
index a00168cdac..93e9b57f77 100644
--- 
a/inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/parser/ParserTools.java
+++ 
b/inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/parser/ParserTools.java
@@ -22,7 +22,8 @@ import lombok.extern.slf4j.Slf4j;
 import net.sf.jsqlparser.expression.Expression;
 import net.sf.jsqlparser.schema.Column;
 import org.reflections.Reflections;
-import org.reflections.scanners.Scanners;
+import org.reflections.scanners.SubTypesScanner;
+import org.reflections.scanners.TypeAnnotationsScanner;
 
 import java.lang.reflect.Constructor;
 import java.util.Map;
@@ -38,7 +39,9 @@ public class ParserTools {
         init();
     }
     private static void init() {
-        Reflections reflections = new Reflections(PARSER_PATH, 
Scanners.TypesAnnotated);
+        Reflections reflections = new Reflections(PARSER_PATH,
+                new TypeAnnotationsScanner(),
+                new SubTypesScanner());
         Set<Class<?>> clazzSet = 
reflections.getTypesAnnotatedWith(TransformParser.class);
         for (Class<?> clazz : clazzSet) {
             if (ValueParser.class.isAssignableFrom(clazz)) {