You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@zeppelin.apache.org by mo...@apache.org on 2017/08/19 17:59:20 UTC
zeppelin git commit: Fixing zeppelin-2281 by clearing output when
data is available
Repository: zeppelin
Updated Branches:
refs/heads/master cbdaf22a9 -> 7b5db0492
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 <sj...@snappydata.io>
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
Project: http://git-wip-us.apache.org/repos/asf/zeppelin/repo
Commit: http://git-wip-us.apache.org/repos/asf/zeppelin/commit/7b5db049
Tree: http://git-wip-us.apache.org/repos/asf/zeppelin/tree/7b5db049
Diff: http://git-wip-us.apache.org/repos/asf/zeppelin/diff/7b5db049
Branch: refs/heads/master
Commit: 7b5db0492d8396892a0fd01c4187298abd111e68
Parents: cbdaf22
Author: Sachin <sj...@snappydata.io>
Authored: Thu Aug 17 10:14:50 2017 +0530
Committer: Lee moon soo <mo...@apache.org>
Committed: Sat Aug 19 10:59:15 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/7b5db049/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 6927b3b..26c9d79 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
@@ -193,11 +193,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 =