mirror of
https://github.com/apache/zeppelin
synced 2026-05-24 09:38:26 +00:00
Removing hadoop-core and print stack trace to failure
This commit is contained in:
parent
5cb7c7b1a2
commit
e821614ddd
2 changed files with 7 additions and 9 deletions
10
beam/pom.xml
10
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>
|
||||
|
|
|
|||
|
|
@ -151,21 +151,25 @@ public class StaticRepl {
|
|||
} 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 {
|
||||
|
|
|
|||
Loading…
Reference in a new issue