diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/util/ClassLoaderUtilsTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/util/ClassLoaderUtilsTest.java index d5f3c9ebded76..654001df254c4 100644 --- a/flink-runtime/src/test/java/org/apache/flink/runtime/util/ClassLoaderUtilsTest.java +++ b/flink-runtime/src/test/java/org/apache/flink/runtime/util/ClassLoaderUtilsTest.java @@ -85,8 +85,6 @@ public void testWithURLClassLoader() { assertTrue(info.indexOf(validJar.getAbsolutePath() + "' (valid") > 0); assertTrue(info.indexOf(invalidJar.getAbsolutePath() + "' (invalid JAR") > 0); assertTrue(info.indexOf(nonExisting.getAbsolutePath() + "' (missing") > 0); - - System.out.println(info); } catch (Exception e) { e.printStackTrace(); @@ -107,7 +105,6 @@ public void testWithURLClassLoader() { @Test public void testWithAppClassLoader() { try { - // must return something when invoked with 'null' String result = ClassLoaderUtil.getUserCodeClassLoaderInfo(ClassLoader.getSystemClassLoader()); assertTrue(result.toLowerCase().contains("system classloader")); } diff --git a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/graph/StreamConfig.java b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/graph/StreamConfig.java index a8486d3cf1a58..4f19db6febcf7 100644 --- a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/graph/StreamConfig.java +++ b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/graph/StreamConfig.java @@ -213,8 +213,8 @@ public T getStreamOperator(ClassLoader cl) { String exceptionMessage = "Cannot load user class: " + e.getMessage() + "\nClassLoader info: " + classLoaderInfo + (loadableDoubleCheck ? - "Class was actually found in classloader - deserialization issue." : - "Class not resolveable through given classloader."); + "\nClass was actually found in classloader - deserialization issue." : + "\nClass not resolvable through given classloader."); throw new StreamTaskException(exceptionMessage); }