[zeppelin] branch master updated: [minor] Fix flaky test in ZeppelinSparkClusterTest

[zjffdu]

This is an automated email from the ASF dual-hosted git repository.

zjffdu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/zeppelin.git


The following commit(s) were added to refs/heads/master by this push:
     new f704043  [minor] Fix flaky test in ZeppelinSparkClusterTest
f704043 is described below

commit f7040438834882427ed738252fac5cedc6088972
Author: Jeff Zhang <zjf...@apache.org>
AuthorDate: Tue Mar 10 13:37:46 2020 +0800

    [minor] Fix flaky test in ZeppelinSparkClusterTest
---
 .../org/apache/zeppelin/integration/ZeppelinSparkClusterTest.java     | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/zeppelin-interpreter-integration/src/test/java/org/apache/zeppelin/integration/ZeppelinSparkClusterTest.java
 
b/zeppelin-interpreter-integration/src/test/java/org/apache/zeppelin/integration/ZeppelinSparkClusterTest.java
index 81e476f..932dd82 100644
--- 
a/zeppelin-interpreter-integration/src/test/java/org/apache/zeppelin/integration/ZeppelinSparkClusterTest.java
+++ 
b/zeppelin-interpreter-integration/src/test/java/org/apache/zeppelin/integration/ZeppelinSparkClusterTest.java
@@ -492,7 +492,7 @@ public abstract class ZeppelinSparkClusterTest extends 
AbstractTestRestApi {
   }
 
   @Test
-  public void zRunTest() throws IOException {
+  public void zRunTest() throws IOException, InterruptedException {
     Note note = null;
     Note note2 = null;
     try {
@@ -536,6 +536,8 @@ public abstract class ZeppelinSparkClusterTest extends 
AbstractTestRestApi {
       p3.setText("%spark println(\"END\")");
 
       note.run(p0.getId(), true);
+      // Sleep 1 second to ensure p3 start running
+      Thread.sleep(1000);
       waitForFinish(p3);
       assertEquals(Status.FINISHED, p3.getStatus());
       assertEquals("END\n", p3.getReturn().message().get(0).getData());