You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@zeppelin.apache.org by zj...@apache.org on 2018/06/15 14:34:20 UTC
zeppelin git commit: [HOTFIX] Fix unit test failure of
NewSparkInterpreterTest
Repository: zeppelin
Updated Branches:
refs/heads/branch-0.8 f50acdf63 -> 974cd5dae
[HOTFIX] Fix unit test failure of NewSparkInterpreterTest
Project: http://git-wip-us.apache.org/repos/asf/zeppelin/repo
Commit: http://git-wip-us.apache.org/repos/asf/zeppelin/commit/974cd5da
Tree: http://git-wip-us.apache.org/repos/asf/zeppelin/tree/974cd5da
Diff: http://git-wip-us.apache.org/repos/asf/zeppelin/diff/974cd5da
Branch: refs/heads/branch-0.8
Commit: 974cd5daed41dc50885a6fa773a027b7f1166de1
Parents: f50acdf
Author: Jeff Zhang <zj...@apache.org>
Authored: Fri Jun 15 22:34:13 2018 +0800
Committer: Jeff Zhang <zj...@apache.org>
Committed: Fri Jun 15 22:34:13 2018 +0800
----------------------------------------------------------------------
.../java/org/apache/zeppelin/spark/NewSparkInterpreterTest.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/zeppelin/blob/974cd5da/spark/interpreter/src/test/java/org/apache/zeppelin/spark/NewSparkInterpreterTest.java
----------------------------------------------------------------------
diff --git a/spark/interpreter/src/test/java/org/apache/zeppelin/spark/NewSparkInterpreterTest.java b/spark/interpreter/src/test/java/org/apache/zeppelin/spark/NewSparkInterpreterTest.java
index 263c38b..25a400c 100644
--- a/spark/interpreter/src/test/java/org/apache/zeppelin/spark/NewSparkInterpreterTest.java
+++ b/spark/interpreter/src/test/java/org/apache/zeppelin/spark/NewSparkInterpreterTest.java
@@ -67,7 +67,7 @@ public class NewSparkInterpreterTest {
// catch the interpreter output in onUpdate
private InterpreterResultMessageOutput messageOutput;
- private RemoteEventClient mockRemoteEventClient = mock(RemoteEventClient.class);
+ private RemoteEventClient mockRemoteEventClient;
@Test
public void testSparkInterpreter() throws IOException, InterruptedException, InterpreterException {
@@ -82,6 +82,7 @@ public class NewSparkInterpreterTest {
interpreter.setInterpreterGroup(mock(InterpreterGroup.class));
interpreter.open();
+ mockRemoteEventClient = mock(RemoteEventClient.class);
interpreter.getZeppelinContext().setEventClient(mockRemoteEventClient);
InterpreterResult result = interpreter.interpret("val a=\"hello world\"", getInterpreterContext());
assertEquals(InterpreterResult.Code.SUCCESS, result.code());