diff --git a/dolphinscheduler-task-plugin/dolphinscheduler-task-datax/src/main/java/org/apache/dolphinscheduler/plugin/task/datax/DataxUtils.java b/dolphinscheduler-task-plugin/dolphinscheduler-task-datax/src/main/java/org/apache/dolphinscheduler/plugin/task/datax/DataxUtils.java index 30b9224d96..33b1f2779e 100644 --- a/dolphinscheduler-task-plugin/dolphinscheduler-task-datax/src/main/java/org/apache/dolphinscheduler/plugin/task/datax/DataxUtils.java +++ b/dolphinscheduler-task-plugin/dolphinscheduler-task-datax/src/main/java/org/apache/dolphinscheduler/plugin/task/datax/DataxUtils.java @@ -68,11 +68,9 @@ public class DataxUtils { case CLICKHOUSE: return DATAX_READER_PLUGIN_CLICKHOUSE; case HIVE: - return DATAX_READER_PLUGIN_RDBMS; case PRESTO: - return DATAX_READER_PLUGIN_RDBMS; default: - return null; + return DATAX_READER_PLUGIN_RDBMS; } } @@ -91,11 +89,9 @@ public class DataxUtils { case DATABEND: return DATAX_WRITER_PLUGIN_DATABEND; case HIVE: - return DATAX_WRITER_PLUGIN_RDBMS; case PRESTO: - return DATAX_WRITER_PLUGIN_RDBMS; default: - return null; + return DATAX_WRITER_PLUGIN_RDBMS; } }