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

restart sparkcluster before sparkr test

Browse source
This commit is contained in:
Lee moon soo 2016-07-18 09:17:55 +09:00
parent 1493b2c05d
commit e3141bd061
1 changed files with 11 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
zeppelin-server/src/test/java/org/apache/zeppelin/rest/ZeppelinSparkClusterTest.java
View file

@ -89,6 +89,17 @@ public class ZeppelinSparkClusterTest extends AbstractTestRestApi {
int sparkVersion = getSparkVersionNumber(note);
if (isSparkR() && sparkVersion >= 14) { // sparkr supported from 1.4.0
// restart spark interpreter
List<InterpreterSetting> settings =
ZeppelinServer.notebook.getBindedInterpreterSettings(note.id());
for (InterpreterSetting setting : settings) {
if (setting.getName().equals("spark")) {
ZeppelinServer.notebook.getInterpreterFactory().restart(setting.getId());
break;
}
}
// run markdown paragraph, again
Paragraph p = note.addParagraph();
Map config = p.getConfig();
@ -98,7 +109,6 @@ public class ZeppelinSparkClusterTest extends AbstractTestRestApi {
"df <- createDataFrame(sqlContext, localDF)\n" +
"count(df)"
);
ps();
note.run(p.getId());
waitForFinish(p);
System.err.println("sparkRTest=" + p.getResult().message());