[incubator-seatunnel] branch dev updated: [hotfix][starrocks] fix error on get starrocks source typeInfo (#4619)

[zongwen]

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

zongwen pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new f7b094f9e [hotfix][starrocks] fix error on get starrocks source 
typeInfo (#4619)
f7b094f9e is described below

commit f7b094f9eb94dafc70c9886def47c82ed9a4613e
Author: Bibo <33744252+531651...@users.noreply.github.com>
AuthorDate: Wed Apr 19 14:21:00 2023 +0800

    [hotfix][starrocks] fix error on get starrocks source typeInfo (#4619)
    
    Co-authored-by: 毕博 <b...@mafengwo.com>
---
 .../connectors/seatunnel/starrocks/source/StarRocksSource.java         | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git 
a/seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/source/StarRocksSource.java
 
b/seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/source/StarRocksSource.java
index 646b75b71..bf468a65e 100644
--- 
a/seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/source/StarRocksSource.java
+++ 
b/seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/source/StarRocksSource.java
@@ -78,8 +78,7 @@ public class StarRocksSource
                             getPluginName(), PluginType.SOURCE, 
mergedConfigCheck.getMsg()));
         }
 
-        Config schemaConfig = 
pluginConfig.getConfig(CatalogTableUtil.SCHEMA.key());
-        this.typeInfo = 
CatalogTableUtil.buildWithConfig(schemaConfig).getSeaTunnelRowType();
+        this.typeInfo = 
CatalogTableUtil.buildWithConfig(pluginConfig).getSeaTunnelRowType();
         this.sourceConfig = SourceConfig.loadConfig(pluginConfig);
     }