From dc7432578f784292db4a100189f5d42e4a75d93e Mon Sep 17 00:00:00 2001 From: egorklimov Date: Wed, 15 Aug 2018 13:05:07 +0300 Subject: [PATCH] NotebookRestApi fixed --- .../java/org/apache/zeppelin/rest/NotebookRestApi.java | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/zeppelin-server/src/main/java/org/apache/zeppelin/rest/NotebookRestApi.java b/zeppelin-server/src/main/java/org/apache/zeppelin/rest/NotebookRestApi.java index 8411263aa84..3258ec02c89 100644 --- a/zeppelin-server/src/main/java/org/apache/zeppelin/rest/NotebookRestApi.java +++ b/zeppelin-server/src/main/java/org/apache/zeppelin/rest/NotebookRestApi.java @@ -751,14 +751,20 @@ public Response runParagraph(@PathParam("noteId") String noteId, throws IOException, IllegalArgumentException { LOG.info("run paragraph job asynchronously {} {} {}", noteId, paragraphId, message); + Note note = notebook.getNote(noteId); + checkIfNoteIsNotNull(note); + Paragraph paragraph = note.getParagraph(paragraphId); + checkIfParagraphIsNotNull(paragraph); + Map params = new HashMap<>(); if (!StringUtils.isEmpty(message)) { RunParagraphWithParametersRequest request = RunParagraphWithParametersRequest.fromJson(message); params = request.getParams(); } - notebookService.runParagraph(noteId, paragraphId, "", "", params, - new HashMap<>(), false, false, getServiceContext(), new RestServiceCallback<>()); + notebookService.runParagraph(noteId, paragraphId, paragraph.getTitle(), + paragraph.getText(), params, new HashMap<>(), + false, false, getServiceContext(), new RestServiceCallback<>()); return new JsonResponse<>(Status.OK).build(); }