You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2021/02/03 11:39:59 UTC

[flink] branch release-1.11 updated: [hotfix][clients] ClientUtils return URLClassLoader

This is an automated email from the ASF dual-hosted git repository.

chesnay pushed a commit to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.11 by this push:
     new ce03675  [hotfix][clients] ClientUtils return URLClassLoader
ce03675 is described below

commit ce036756634e9b91a1c7d3e16af1eb477345e2e1
Author: Chesnay Schepler <ch...@apache.org>
AuthorDate: Wed Feb 3 12:38:24 2021 +0100

    [hotfix][clients] ClientUtils return URLClassLoader
---
 flink-clients/src/main/java/org/apache/flink/client/ClientUtils.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/flink-clients/src/main/java/org/apache/flink/client/ClientUtils.java b/flink-clients/src/main/java/org/apache/flink/client/ClientUtils.java
index 612ca5c..3db724b 100644
--- a/flink-clients/src/main/java/org/apache/flink/client/ClientUtils.java
+++ b/flink-clients/src/main/java/org/apache/flink/client/ClientUtils.java
@@ -40,6 +40,7 @@ import org.slf4j.LoggerFactory;
 
 import java.io.IOException;
 import java.net.URL;
+import java.net.URLClassLoader;
 import java.util.List;
 import java.util.concurrent.ExecutionException;
 
@@ -52,7 +53,7 @@ public enum ClientUtils {
 
     private static final Logger LOG = LoggerFactory.getLogger(ClientUtils.class);
 
-    public static ClassLoader buildUserCodeClassLoader(
+    public static URLClassLoader buildUserCodeClassLoader(
             List<URL> jars, List<URL> classpaths, ClassLoader parent, Configuration configuration) {
         URL[] urls = new URL[jars.size() + classpaths.size()];
         for (int i = 0; i < jars.size(); i++) {