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

zjffdu 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 232e0a6  [ZEPPELIN-4565] Fixed Spark interpreter to allow 
ZeppelinContext binding in windows
232e0a6 is described below

commit 232e0a6c187d67b211b0a99facbe5c982431c398
Author: Muhammad Taufiq <muhammad.tau...@morganstanley.com>
AuthorDate: Thu Jan 16 17:14:00 2020 +0000

    [ZEPPELIN-4565] Fixed Spark interpreter to allow ZeppelinContext binding in 
windows
    
    ### What is this PR for?
    ZeppelinContext binding fails for Spark Interpreter in Windows because of 
the jars not being added to the classpath. This happens because the path of the 
jars is not supported in Windows.
    
    ### What type of PR is it?
    Bug Fix
    
    ### What is the Jira issue?
    * https://issues.apache.org/jira/browse/ZEPPELIN-4565
    
    THIS SOFTWARE IS CONTRIBUTED SUBJECT TO THE TERMS OF THE APACHE SOFTWARE 
FOUNDATION SOFTWARE GRANT AND CORPORATE CONTRIBUTOR LICENSE AGREEMENT VERSION 
R190612.
    
    THIS SOFTWARE IS LICENSED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" 
AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 
IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE AND 
ANY WARRANTY OF NON-INFRINGEMENT, ARE DISCLAIMED. IN NO EVENT SHALL THE 
COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, 
SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, 
PROCUREMENT OF SUBSTITUTE GOODS [...]
    
    Author: Muhammad Taufiq <muhammad.tau...@morganstanley.com>
    
    Closes #3605 from Muhammad-ms/zeppelin9_spark_binding_fixed and squashes 
the following commits:
    
    7afb8196f [Muhammad Taufiq] [ZEPPELIN-4565] Fixed Spark interpreter to 
allow ZeppelinContext binding in windows
---
 .../scala/org/apache/zeppelin/spark/BaseSparkScalaInterpreter.scala   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/spark/spark-scala-parent/src/main/scala/org/apache/zeppelin/spark/BaseSparkScalaInterpreter.scala
 
b/spark/spark-scala-parent/src/main/scala/org/apache/zeppelin/spark/BaseSparkScalaInterpreter.scala
index e62fc96..6b22dd8 100644
--- 
a/spark/spark-scala-parent/src/main/scala/org/apache/zeppelin/spark/BaseSparkScalaInterpreter.scala
+++ 
b/spark/spark-scala-parent/src/main/scala/org/apache/zeppelin/spark/BaseSparkScalaInterpreter.scala
@@ -405,7 +405,7 @@ abstract class BaseSparkScalaInterpreter(val conf: 
SparkConf,
       }
     }
 
-    extraJars ++= sparkInterpreterClassLoader.getURLs().map(_.toString)
+    extraJars ++= sparkInterpreterClassLoader.getURLs().map(_.getPath())
     LOGGER.debug("User jar for spark repl: " + extraJars.mkString(","))
     extraJars
   }
@@ -417,4 +417,4 @@ abstract class BaseSparkScalaInterpreter(val conf: 
SparkConf,
 
 object BaseSparkScalaInterpreter {
   val sessionNum = new AtomicInteger(0)
-}
\ No newline at end of file
+}

Reply via email to