We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 1e32a2e commit 049cf2bCopy full SHA for 049cf2b
core/src/main/java/com/dtstack/flink/sql/exec/ExecuteProcessHelper.java
@@ -138,8 +138,7 @@ public static ParamsInfo parseParams(String[] args) throws Exception {
138
}
139
140
if (!pluginLoadMode.equalsIgnoreCase(EPluginLoadMode.LOCALTEST.name()) && Objects.isNull(dirtyProperties.get(PLUGIN_PATH_STR))) {
141
- dirtyProperties.put(PLUGIN_PATH_STR,
142
- Objects.isNull(remoteSqlPluginPath) ? localSqlPluginPath : remoteSqlPluginPath);
+ dirtyProperties.put(PLUGIN_PATH_STR, localSqlPluginPath);
143
144
145
List<URL> jarUrlList = getExternalJarUrls(options.getAddjar());
0 commit comments