We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent fd8dc57 commit 2330da5Copy full SHA for 2330da5
1 file changed
core/src/main/java/com/dtstack/flink/sql/side/SideSqlExec.java
@@ -20,6 +20,7 @@
20
21
package com.dtstack.flink.sql.side;
22
23
+import com.dtstack.flink.sql.enums.EPluginLoadMode;
24
import org.apache.flink.api.common.typeinfo.TypeInformation;
25
import org.apache.flink.api.common.typeinfo.Types;
26
import org.apache.flink.api.java.tuple.Tuple2;
@@ -104,7 +105,7 @@ public void exec(String sql,
104
105
Map<String, Table> tableCache,
106
CreateTmpTableParser.SqlParserResult createView,
107
String scope) throws Exception {
- if (localSqlPluginPath == null) {
108
+ if (localSqlPluginPath == null && !pluginLoadMode.equals(EPluginLoadMode.LOCALTEST.name())) {
109
throw new RuntimeException("need to set localSqlPluginPath");
110
}
111
0 commit comments