[zeppelin] branch master updated: Use Classloader class for flink creation (#4605)

[jongyoul]

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

jongyoul pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/zeppelin.git


The following commit(s) were added to refs/heads/master by this push:
     new 858de898d2 Use Classloader class for flink creation (#4605)
858de898d2 is described below

commit 858de898d2663d566f193fdabe17e15953e63547
Author: Philipp Dallig <philipp.dal...@gmail.com>
AuthorDate: Tue May 30 08:50:33 2023 +0200

    Use Classloader class for flink creation (#4605)
---
 .../main/scala/org/apache/zeppelin/flink/FlinkScala211Interpreter.scala | 2 +-
 .../main/scala/org/apache/zeppelin/flink/FlinkScala212Interpreter.scala | 2 +-
 .../src/main/java/org/apache/zeppelin/flink/FlinkInterpreter.java       | 2 +-
 .../main/scala/org/apache/zeppelin/flink/FlinkScalaInterpreter.scala    | 2 +-
 4 files changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/flink/flink-scala-2.11/src/main/scala/org/apache/zeppelin/flink/FlinkScala211Interpreter.scala
 
b/flink/flink-scala-2.11/src/main/scala/org/apache/zeppelin/flink/FlinkScala211Interpreter.scala
index 66b74bd84d..fc40df029d 100644
--- 
a/flink/flink-scala-2.11/src/main/scala/org/apache/zeppelin/flink/FlinkScala211Interpreter.scala
+++ 
b/flink/flink-scala-2.11/src/main/scala/org/apache/zeppelin/flink/FlinkScala211Interpreter.scala
@@ -30,7 +30,7 @@ import scala.tools.nsc.interpreter.{IMain, JPrintWriter}
 
 
 class FlinkScala211Interpreter(override val properties: Properties,
-                               override val flinkScalaClassLoader: 
URLClassLoader)
+                               override val flinkScalaClassLoader: ClassLoader)
   extends FlinkScalaInterpreter(properties, flinkScalaClassLoader) {
 
   override def completion(buf: String,
diff --git 
a/flink/flink-scala-2.12/src/main/scala/org/apache/zeppelin/flink/FlinkScala212Interpreter.scala
 
b/flink/flink-scala-2.12/src/main/scala/org/apache/zeppelin/flink/FlinkScala212Interpreter.scala
index f1bfcfe6a6..b7af4ad3b1 100644
--- 
a/flink/flink-scala-2.12/src/main/scala/org/apache/zeppelin/flink/FlinkScala212Interpreter.scala
+++ 
b/flink/flink-scala-2.12/src/main/scala/org/apache/zeppelin/flink/FlinkScala212Interpreter.scala
@@ -29,7 +29,7 @@ import scala.tools.nsc.Settings
 import scala.tools.nsc.interpreter.{IMain, JPrintWriter}
 
 class FlinkScala212Interpreter(override val properties: Properties,
-                               override val flinkScalaClassLoader: 
URLClassLoader)
+                               override val flinkScalaClassLoader: ClassLoader)
   extends FlinkScalaInterpreter(properties, flinkScalaClassLoader) {
 
   override def completion(buf: String,
diff --git 
a/flink/flink-scala-parent/src/main/java/org/apache/zeppelin/flink/FlinkInterpreter.java
 
b/flink/flink-scala-parent/src/main/java/org/apache/zeppelin/flink/FlinkInterpreter.java
index a10128f94c..439a0e26d4 100644
--- 
a/flink/flink-scala-parent/src/main/java/org/apache/zeppelin/flink/FlinkInterpreter.java
+++ 
b/flink/flink-scala-parent/src/main/java/org/apache/zeppelin/flink/FlinkInterpreter.java
@@ -90,7 +90,7 @@ public class FlinkInterpreter extends Interpreter {
     Class<?> clazz = Class.forName(innerIntpClassName);
 
     return (FlinkScalaInterpreter)
-            clazz.getConstructor(Properties.class, URLClassLoader.class)
+            clazz.getConstructor(Properties.class, ClassLoader.class)
                     .newInstance(getProperties(), flinkScalaClassLoader);
   }
 
diff --git 
a/flink/flink-scala-parent/src/main/scala/org/apache/zeppelin/flink/FlinkScalaInterpreter.scala
 
b/flink/flink-scala-parent/src/main/scala/org/apache/zeppelin/flink/FlinkScalaInterpreter.scala
index d5bf2fc14e..c6ce85c985 100644
--- 
a/flink/flink-scala-parent/src/main/scala/org/apache/zeppelin/flink/FlinkScalaInterpreter.scala
+++ 
b/flink/flink-scala-parent/src/main/scala/org/apache/zeppelin/flink/FlinkScalaInterpreter.scala
@@ -65,7 +65,7 @@ import scala.tools.nsc.interpreter.{Completion, IMain, IR, 
JPrintWriter, Results
  * @param properties
  */
 abstract class FlinkScalaInterpreter(val properties: Properties,
-                                     val flinkScalaClassLoader: 
URLClassLoader) {
+                                     val flinkScalaClassLoader: ClassLoader) {
 
   private lazy val LOGGER: Logger = LoggerFactory.getLogger(getClass)