From 4a8f3a7e8a9d83e9058cb63f32750f1d58799ed2 Mon Sep 17 00:00:00 2001 From: wenlx Date: Mon, 7 Nov 2022 14:56:23 +0800 Subject: [PATCH] Fix bug of auth failed when using special character in fs.uris --- .../kafka/connect/fs/policy/AbstractPolicy.java | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/src/main/java/com/github/mmolimar/kafka/connect/fs/policy/AbstractPolicy.java b/src/main/java/com/github/mmolimar/kafka/connect/fs/policy/AbstractPolicy.java index d55cf90..43ec85a 100644 --- a/src/main/java/com/github/mmolimar/kafka/connect/fs/policy/AbstractPolicy.java +++ b/src/main/java/com/github/mmolimar/kafka/connect/fs/policy/AbstractPolicy.java @@ -16,6 +16,8 @@ import org.slf4j.LoggerFactory; import java.io.IOException; +import java.net.URI; +import java.net.URISyntaxException; import java.time.LocalDateTime; import java.time.format.DateTimeFormatter; import java.util.*; @@ -85,7 +87,13 @@ private void configFs(Map customConfigs) throws IOException { (String) entry.getValue())); Path workingDir = new Path(convert(uri)); - FileSystem fs = FileSystem.newInstance(workingDir.toUri(), fsConfig); + URI fsUri; + try { + fsUri = new URI(convert(uri)); + } catch (URISyntaxException e) { + throw new IllegalArgumentException("Uri syntax is invalid, uri: " + uri, e); + } + FileSystem fs = FileSystem.newInstance(fsUri, fsConfig); fs.setWorkingDirectory(workingDir); this.fileSystems.add(fs); }