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 apache#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
Elvis0607 · Aug 19, 2017 · 7b5db04 · 7b5db04
1 parent cbdaf22
commit 7b5db04
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...er/src/main/java/org/apache/zeppelin/interpreter/remote/RemoteInterpreterEventPoller.java b/...er/src/main/java/org/apache/zeppelin/interpreter/remote/RemoteInterpreterEventPoller.java
@@ -193,11 +193,11 @@ public void run() {
           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 =