[zeppelin] branch master updated: [hotfix] HotFix for test failure of StandardInterpreterLauncherTest

[zj...@apache.org]

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 98b26a1  [hotfix] HotFix for test failure of StandardInterpreterLauncherTest
98b26a1 is described below

commit 98b26a12f4ebe73e9ab9aa011e9a8a56731addbe
Author: Jeff Zhang <zj...@apache.org>
AuthorDate: Thu Apr 9 15:40:42 2020 +0800

    [hotfix] HotFix for test failure of StandardInterpreterLauncherTest
---
 .../interpreter/launcher/StandardInterpreterLauncherTest.java       | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/zeppelin-zengine/src/test/java/org/apache/zeppelin/interpreter/launcher/StandardInterpreterLauncherTest.java b/zeppelin-zengine/src/test/java/org/apache/zeppelin/interpreter/launcher/StandardInterpreterLauncherTest.java
index 60bf915..b7d0cbf 100644
--- a/zeppelin-zengine/src/test/java/org/apache/zeppelin/interpreter/launcher/StandardInterpreterLauncherTest.java
+++ b/zeppelin-zengine/src/test/java/org/apache/zeppelin/interpreter/launcher/StandardInterpreterLauncherTest.java
@@ -56,8 +56,9 @@ public class StandardInterpreterLauncherTest {
     assertEquals(ZeppelinConfiguration.ConfVars.ZEPPELIN_INTERPRETER_CONNECT_TIMEOUT.getIntValue(),
         interpreterProcess.getConnectTimeout());
     assertEquals(zConf.getInterpreterRemoteRunnerPath(), interpreterProcess.getInterpreterRunner());
-    assertEquals(2, interpreterProcess.getEnv().size());
+    assertTrue(interpreterProcess.getEnv().size() >= 2);
     assertEquals("VALUE_1", interpreterProcess.getEnv().get("ENV_1"));
+    assertTrue(interpreterProcess.getEnv().containsKey("INTERPRETER_GROUP_ID"));
     assertEquals(true, interpreterProcess.isUserImpersonated());
   }
 
@@ -79,7 +80,8 @@ public class StandardInterpreterLauncherTest {
     assertEquals(".//local-repo/groupId", interpreterProcess.getLocalRepoDir());
     assertEquals(10000, interpreterProcess.getConnectTimeout());
     assertEquals(zConf.getInterpreterRemoteRunnerPath(), interpreterProcess.getInterpreterRunner());
-    assertEquals(1, interpreterProcess.getEnv().size());
+    assertTrue(interpreterProcess.getEnv().size() >= 1);
+    assertTrue(interpreterProcess.getEnv().containsKey("INTERPRETER_GROUP_ID"));
     assertEquals(true, interpreterProcess.isUserImpersonated());
   }