This is an automated email from the ASF dual-hosted git repository. xyz pushed a commit to branch branch-2.8 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit c038898608ac901e81093b38c2dc82cf5051265b Author: Yunze Xu <[email protected]> AuthorDate: Sat Aug 6 03:00:55 2022 +0800 Fix AuthenticationProviderBasicTest --- .../authentication/AuthenticationProviderBasicTest.java | 2 +- .../src/main/java/org/apache/pulsar/client/api/url/URL.java | 11 +++++++++++ 2 files changed, 12 insertions(+), 1 deletion(-) diff --git a/pulsar-broker-common/src/test/java/org/apache/pulsar/broker/authentication/AuthenticationProviderBasicTest.java b/pulsar-broker-common/src/test/java/org/apache/pulsar/broker/authentication/AuthenticationProviderBasicTest.java index 69df6663bd1..e5a7f20c978 100644 --- a/pulsar-broker-common/src/test/java/org/apache/pulsar/broker/authentication/AuthenticationProviderBasicTest.java +++ b/pulsar-broker-common/src/test/java/org/apache/pulsar/broker/authentication/AuthenticationProviderBasicTest.java @@ -91,7 +91,7 @@ public class AuthenticationProviderBasicTest { @Test public void testReadData() throws Exception { - byte[] data = Files.readAllBytes(Path.of(basicAuthConf)); + byte[] data = Files.readAllBytes(FileSystems.getDefault().getPath(basicAuthConf)); String base64Data = Base64.getEncoder().encodeToString(data); // base64 format diff --git a/pulsar-common/src/main/java/org/apache/pulsar/client/api/url/URL.java b/pulsar-common/src/main/java/org/apache/pulsar/client/api/url/URL.java index b2037377d2f..3286900ecb7 100644 --- a/pulsar-common/src/main/java/org/apache/pulsar/client/api/url/URL.java +++ b/pulsar-common/src/main/java/org/apache/pulsar/client/api/url/URL.java @@ -42,6 +42,17 @@ public class URL { } } + /** + * Creates java.net.URL with data protocol support. + * + * @param spec the input URL as String + * @return java.net.URL instance + */ + public static final java.net.URL createURL(String spec) + throws MalformedURLException, URISyntaxException, InstantiationException, IllegalAccessException { + return new URL(spec).url; + } + public URLConnection openConnection() throws IOException { return this.url.openConnection(); }
