You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2016/01/15 11:53:39 UTC
[09/12] flink git commit: [FLINK-3236] [runtime] Flink user code
classloader as parent classloader from Flink core classes
[FLINK-3236] [runtime] Flink user code classloader as parent classloader from Flink core classes
Originally, the user code classloader delegates to the system classloader as parent.
That works in Flink standalone settings, but not when the Flink core classes themselves
are not loaded with the system classloader (certain embedded setups).
This patch uses as parent the classloader that was used to load the Flink core classes, specificly
"org.apache.flink.runtime.execution.librarycache.BlobLibraryCacheManager.FlinkUserCodeClassLoader.class.getClassLoader()".
This closes #1506
This closes #1507
This closes #1508
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0ae46b59
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0ae46b59
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/0ae46b59
Branch: refs/heads/master
Commit: 0ae46b596949808f56c40bd7a68f478bc10206ab
Parents: 388c280
Author: Prez Cannady <re...@opencorrelate.org>
Authored: Thu Jan 14 10:15:12 2016 -0500
Committer: Stephan Ewen <se...@apache.org>
Committed: Fri Jan 15 11:44:20 2016 +0100
----------------------------------------------------------------------
.../runtime/execution/librarycache/BlobLibraryCacheManager.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/0ae46b59/flink-runtime/src/main/java/org/apache/flink/runtime/execution/librarycache/BlobLibraryCacheManager.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/execution/librarycache/BlobLibraryCacheManager.java b/flink-runtime/src/main/java/org/apache/flink/runtime/execution/librarycache/BlobLibraryCacheManager.java
index 97ec93a..98caac4 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/execution/librarycache/BlobLibraryCacheManager.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/execution/librarycache/BlobLibraryCacheManager.java
@@ -326,7 +326,7 @@ public final class BlobLibraryCacheManager extends TimerTask implements LibraryC
private static class FlinkUserCodeClassLoader extends URLClassLoader {
public FlinkUserCodeClassLoader(URL[] urls) {
- super(urls);
+ super(urls, FlinkUserCodeClassLoader.class.getClassLoader());
}
}
}