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.
2 parents b378a0e + adeb5a0 commit 8c19de4Copy full SHA for 8c19de4
core/src/main/java/com/dtstack/flink/sql/util/PluginUtil.java
@@ -186,7 +186,14 @@ public static URL buildDirtyPluginUrl(
186
prefix,
187
pluginLoadMode
188
);
189
- String path = remotePath == null ? localPath : remotePath;
+
190
+ String path;
191
+ if (StringUtils.equalsIgnoreCase(pluginLoadMode, EPluginLoadMode.CLASSPATH.name())) {
192
+ path = remotePath == null ? localPath : remotePath;
193
+ } else {
194
+ path = localPath;
195
+ }
196
197
String dirtyPath = path + SP + DIRTY_DATA_PRE + SP + dirtyType;
198
URI uri = URI.create("file:" + dirtyPath + SP + jarFileName);
199
return uri.toURL();
0 commit comments