Elgato_dark/zeppelin
1
0
Fork 0
mirror of https://github.com/apache/zeppelin synced 2026-05-24 09:38:26 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

set spark version to 1.6.1 and some modifications

Browse source
This commit is contained in:
mahmoudelgamal 2016-09-17 23:02:32 +02:00
parent 750041cbf8
commit 27d769005e
3 changed files with 12 additions and 23 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
beam/pom.xml
View file

@ -34,11 +34,17 @@
<properties>
<beam.hadoop.version>2.3.0</beam.hadoop.version>
<beam.spark.version>1.4.1</beam.spark.version>
<beam.spark.version>1.6.1</beam.spark.version>
<beam.beam.version>0.2.0-incubating</beam.beam.version>
</properties>
<dependencies>
<dependency>
<groupId>io.netty</groupId>
<artifactId>netty-all</artifactId>
<version>4.1.1.Final</version>
</dependency>
<dependency>
<groupId>org.apache.spark</groupId>
<artifactId>spark-core_2.10</artifactId>

2
beam/src/main/java/org/apache/zeppelin/beam/BeamInterpreter.java
View file

@ -53,7 +53,7 @@ public class BeamInterpreter extends Interpreter {
// delete all .class files created while compilation process
for (int i = 0; i < dir.list().length; i++) {
File f = dir.listFiles()[i];
if (f.getAbsolutePath().contains(".class")) {
if (f.getAbsolutePath().endsWith(".class")) {
f.delete();
}
}

25
beam/src/main/java/org/apache/zeppelin/beam/StaticRepl.java
View file

@ -147,27 +147,10 @@ public class StaticRepl {
return baosOut.toString();
} 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);
System.err.println("Invocation target: " + e);
} catch (ClassNotFoundException | NoSuchMethodException | IllegalAccessException
| InvocationTargetException e) {
logger.error("Exception in Interpreter while execution", e);
System.err.println(e);
e.printStackTrace(newErr);
throw new Exception(baosErr.toString());