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

fixed api method for runNoteJob in notebook rest api

Browse source
This commit is contained in:
CloverHearts 2016-07-29 16:45:27 +09:00
parent 7cc908b3a1
commit 251bb5246d
1 changed files with 19 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
zeppelin-server/src/main/java/org/apache/zeppelin/rest/NotebookRestApi.java
View file

@ -39,6 +39,8 @@ import com.google.common.collect.Sets;
import com.google.common.reflect.TypeToken;
import com.google.gson.Gson;
import org.apache.commons.lang3.StringUtils;
import org.apache.zeppelin.interpreter.InterpreterResult;
import org.apache.zeppelin.scheduler.Job;
import org.quartz.CronExpression;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@ -498,7 +500,23 @@ public class NotebookRestApi {
return new JsonResponse<>(Status.NOT_FOUND, "note not found.").build();
}
note.runAll();
for (Paragraph paragraph : note.getParagraphs()) {
note.setLastReplName(paragraph.getId());
try {
note.run(paragraph.getId());
} catch (Exception ex) {
LOG.error("Exception from run", ex);
if (paragraph != null) {
paragraph.setReturn(
new InterpreterResult(InterpreterResult.Code.ERROR, ex.getMessage()),
ex);
paragraph.setStatus(Job.Status.ERROR);
}
return new JsonResponse<>(Status.PRECONDITION_FAILED,
paragraph.getJobName() + " Not selected or Invalid Interpreter bind").build();
}
}
return new JsonResponse<>(Status.OK).build();
}