Repository: zeppelin Updated Branches: refs/heads/branch-0.7 742994f81 -> b2164e9fd
Fixing zeppelin-2281 by clearing output when data is available ### What is this PR for? Fixing ZEPPELIN-2281 by clearing previous when new data is available ### What type of PR is it? [Bug Fix] ### Todos * [x] - Task ### What is the Jira issue? * https://issues.apache.org/jira/browse/ZEPPELIN-2281 ### How should this be tested? * Execute a paragraph and see the output * Execute the same paragraph again but abort it before completion and see the output.Paragraph is clear and previous output is lost ### Screenshots (if appropriate) ### Questions: * Does the licenses files need update? NA * Is there breaking changes for older versions? NA * Does this needs documentation? NA Author: Sachin <[email protected]> Closes #2518 from SachinJanani/ZEPPELIN-2281 and squashes the following commits: 5e276b9 [Sachin] Merge branch 'master' into ZEPPELIN-2281 c5ace52 [Sachin] Fixing zeppelin-2281 by clearing output when data is available (cherry picked from commit 7b5db0492d8396892a0fd01c4187298abd111e68) Signed-off-by: Lee moon soo <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/zeppelin/repo Commit: http://git-wip-us.apache.org/repos/asf/zeppelin/commit/b2164e9f Tree: http://git-wip-us.apache.org/repos/asf/zeppelin/tree/b2164e9f Diff: http://git-wip-us.apache.org/repos/asf/zeppelin/diff/b2164e9f Branch: refs/heads/branch-0.7 Commit: b2164e9fd12176242eda5d73662b237792f064d6 Parents: 742994f Author: Sachin <[email protected]> Authored: Thu Aug 17 10:14:50 2017 +0530 Committer: Lee moon soo <[email protected]> Committed: Sat Aug 19 10:59:26 2017 -0700 ---------------------------------------------------------------------- .../zeppelin/interpreter/remote/RemoteInterpreterEventPoller.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/zeppelin/blob/b2164e9f/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/remote/RemoteInterpreterEventPoller.java ---------------------------------------------------------------------- diff --git a/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/remote/RemoteInterpreterEventPoller.java b/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/remote/RemoteInterpreterEventPoller.java index e2a8add..468c0e8 100644 --- a/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/remote/RemoteInterpreterEventPoller.java +++ b/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/remote/RemoteInterpreterEventPoller.java @@ -183,11 +183,11 @@ public class RemoteInterpreterEventPoller extends Thread { String paragraphId = (String) outputUpdate.get("paragraphId"); // clear the output - listener.onOutputClear(noteId, paragraphId); List<Map<String, String>> messages = (List<Map<String, String>>) outputUpdate.get("messages"); if (messages != null) { + listener.onOutputClear(noteId, paragraphId); for (int i = 0; i < messages.size(); i++) { Map<String, String> m = messages.get(i); InterpreterResult.Type type =
