Removing hadoop-core and print stack trace to failure

novelari · Aug 30, 2016 · dd28af7 · dd28af7
1 parent c159deb
commit dd28af7
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 9 deletions.
diff --git a/beam/pom.xml b/beam/pom.xml
@@ -66,7 +66,7 @@
       <artifactId>spark-streaming_2.10</artifactId>
       <version>${beam.spark.version}</version>
     </dependency>
-  
+
     <dependency>
       <groupId>org.apache.hadoop</groupId>
       <artifactId>hadoop-mapreduce-client-core</artifactId>
@@ -132,13 +132,7 @@
         </exclusion>
       </exclusions>
     </dependency>
-
-    <dependency>
-      <groupId>org.apache.hadoop</groupId>
-      <artifactId>hadoop-core</artifactId>
-      <version>1.2.1</version>
-    </dependency>
-
+
     <dependency>
       <groupId>com.thoughtworks.qdox</groupId>
       <artifactId>qdox</artifactId>

diff --git a/beam/src/main/java/org/apache/zeppelin/beam/StaticRepl.java b/beam/src/main/java/org/apache/zeppelin/beam/StaticRepl.java
@@ -151,21 +151,25 @@ public static String execute(String generatedClassName, String code) throws Exce
       } catch (ClassNotFoundException e) {
         LOGGER.error("Exception in Interpreter while Class not found", e);
         System.err.println("Class not found: " + e);
+        e.printStackTrace(newErr);
         throw new Exception(baosErr.toString());
 
       } catch (NoSuchMethodException e) {
         LOGGER.error("Exception in Interpreter while No such method", e);
         System.err.println("No such method: " + e);
+        e.printStackTrace(newErr);
         throw new Exception(baosErr.toString());
 
       } catch (IllegalAccessException e) {
         LOGGER.error("Exception in Interpreter while Illegal access", e);
         System.err.println("Illegal access: " + e);
+        e.printStackTrace(newErr);
         throw new Exception(baosErr.toString());
 
       } catch (InvocationTargetException e) {
-        LOGGER.error("Exception in Interpreter while Invocation target", e);
+        LOGGER.error("Exception in Interpreter while Invocation target", e);      
         System.err.println("Invocation target: " + e);
+        e.printStackTrace(newErr);
         throw new Exception(baosErr.toString());
 
       } finally {