Skip to content

Commit adeb5a0

Browse files
committed
[hotfix-37120][core] fix dirty plugin url was wrong when remote-plugin-path was 'hdfs://'.
1 parent 60d020f commit adeb5a0

File tree

1 file changed

+8
-1
lines changed

1 file changed

+8
-1
lines changed

core/src/main/java/com/dtstack/flink/sql/util/PluginUtil.java

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -186,7 +186,14 @@ public static URL buildDirtyPluginUrl(
186186
prefix,
187187
pluginLoadMode
188188
);
189-
String path = remotePath == null ? localPath : remotePath;
189+
190+
String path;
191+
if (StringUtils.equalsIgnoreCase(pluginLoadMode, EPluginLoadMode.CLASSPATH.name())) {
192+
path = remotePath == null ? localPath : remotePath;
193+
} else {
194+
path = localPath;
195+
}
196+
190197
String dirtyPath = path + SP + DIRTY_DATA_PRE + SP + dirtyType;
191198
URI uri = URI.create("file:" + dirtyPath + SP + jarFileName);
192199
return uri.toURL();

0 commit comments

Comments
 (0)