(inlong) branch master updated: [INLONG-11074][Sort] Transform support dummy select when the transform sql is empty (#11075)

[al...@apache.org]

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

aloyszhang 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 6099a13668 [INLONG-11074][Sort] Transform support dummy select when the transform sql is empty (#11075)
6099a13668 is described below

commit 6099a13668305efda2a4da20d4a8c000be16dffb
Author: vernedeng <ve...@apache.org>
AuthorDate: Tue Sep 10 11:56:23 2024 +0800

    [INLONG-11074][Sort] Transform support dummy select when the transform sql is empty (#11075)
---
 .../inlong/sdk/transform/process/TransformProcessor.java     | 12 +++++++++---
 1 file changed, 9 insertions(+), 3 deletions(-)

diff --git a/inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/TransformProcessor.java b/inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/TransformProcessor.java
index ba8888adde..62e8ebf96a 100644
--- a/inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/TransformProcessor.java
+++ b/inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/TransformProcessor.java
@@ -53,6 +53,7 @@ public class TransformProcessor<I, O> {
     private static final Logger LOG = LoggerFactory.getLogger(TransformProcessor.class);
 
     private static final Map<String, Object> EMPTY_EXT_PARAMS = ImmutableMap.of();
+    private static final String DUMMY_SELECT = "select *";
 
     private final TransformConfig config;
     private final SourceDecoder<I> decoder;
@@ -88,12 +89,17 @@ public class TransformProcessor<I, O> {
             this.sinkFieldList = new ArrayList<>(fields.size());
             fields.forEach(v -> this.sinkFieldList.add(v.getName()));
         }
-        this.initTransformSql();
+
+        if (StringUtils.isNotEmpty(config.getTransformSql())) {
+            this.initTransformSql(config.getTransformSql());
+        } else {
+            this.initTransformSql(DUMMY_SELECT);
+        }
     }
 
-    private void initTransformSql() throws JSQLParserException {
+    private void initTransformSql(String sql) throws JSQLParserException {
         CCJSqlParserManager parserManager = new CCJSqlParserManager();
-        Select select = (Select) parserManager.parse(new StringReader(config.getTransformSql()));
+        Select select = (Select) parserManager.parse(new StringReader(sql));
         this.transformSelect = (PlainSelect) select.getSelectBody();
         this.where = OperatorTools.buildOperator(this.transformSelect.getWhere());
         List<SelectItem> items = this.transformSelect.getSelectItems();