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

zihaoxiang pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git


The following commit(s) were added to refs/heads/dev by this push:
     new 5e135ba041 fix: execute sql error: datasource plugin 'doris' is not 
found。 (#15123)
5e135ba041 is described below

commit 5e135ba041cb6e4ca3c1825fd4985d8b8da99932
Author: Xinxing <[email protected]>
AuthorDate: Tue Nov 7 14:37:07 2023 +0800

    fix: execute sql error: datasource plugin 'doris' is not found。 (#15123)
    
    Co-authored-by: xiangzihao <[email protected]>
---
 .../plugin/doris/DorisDataSourceChannelFactory.java                 | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git 
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-doris/src/main/java/org/apache/dolphinscheduler/plugin/doris/DorisDataSourceChannelFactory.java
 
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-doris/src/main/java/org/apache/dolphinscheduler/plugin/doris/DorisDataSourceChannelFactory.java
index 5fe7bda4f0..d663c362f2 100644
--- 
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-doris/src/main/java/org/apache/dolphinscheduler/plugin/doris/DorisDataSourceChannelFactory.java
+++ 
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-doris/src/main/java/org/apache/dolphinscheduler/plugin/doris/DorisDataSourceChannelFactory.java
@@ -18,7 +18,11 @@ package org.apache.dolphinscheduler.plugin.doris;
 
 import org.apache.dolphinscheduler.spi.datasource.DataSourceChannel;
 import org.apache.dolphinscheduler.spi.datasource.DataSourceChannelFactory;
+import org.apache.dolphinscheduler.spi.enums.DbType;
 
+import com.google.auto.service.AutoService;
+
+@AutoService(DataSourceChannelFactory.class)
 public class DorisDataSourceChannelFactory implements DataSourceChannelFactory 
{
 
     @Override
@@ -28,6 +32,6 @@ public class DorisDataSourceChannelFactory implements 
DataSourceChannelFactory {
 
     @Override
     public String getName() {
-        return "doris";
+        return DbType.DORIS.getDescp();
     }
 }

Reply via email to