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();
}
}