zeppelin-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From m...@apache.org
Subject zeppelin git commit: Fixing zeppelin-2281 by clearing output when data is available
Date Sat, 19 Aug 2017 17:59:33 GMT
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 <sjanani@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

(cherry picked from commit 7b5db0492d8396892a0fd01c4187298abd111e68)
Signed-off-by: Lee moon soo <moon@apache.org>


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 <sjanani@snappydata.io>
Authored: Thu Aug 17 10:14:50 2017 +0530
Committer: Lee moon soo <moon@apache.org>
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 =


Mime
View raw message