Removing hadoop-core and print stack trace to failure

This commit is contained in:
mahmoudelgamal 2016-08-30 12:37:47 +02:00
parent 5cb7c7b1a2
commit e821614ddd
2 changed files with 7 additions and 9 deletions

View file

@ -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>

View file

@ -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 {