You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@zeppelin.apache.org by pd...@apache.org on 2021/01/04 15:34:28 UTC
[zeppelin] branch master updated: [ZEPPELIN-5187] Use new
constructor introduced with ZEPPELIN-5170
This is an automated email from the ASF dual-hosted git repository.
pdallig 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 71d2508 [ZEPPELIN-5187] Use new constructor introduced with ZEPPELIN-5170
71d2508 is described below
commit 71d250800ac704b36acc719e7866ee964303b152
Author: Philipp Dallig <ph...@gmail.com>
AuthorDate: Mon Jan 4 14:28:20 2021 +0100
[ZEPPELIN-5187] Use new constructor introduced with ZEPPELIN-5170
### What is this PR for?
This PR fixes NPE exceptions in our tests.
### What type of PR is it?
- Hot Fix
### What is the Jira issue?
* https://issues.apache.org/jira/browse/ZEPPELIN-5187
### Questions:
* Does the licenses files need update? No
* Is there breaking changes for older versions? No
* Does this needs documentation? No
Author: Philipp Dallig <ph...@gmail.com>
Closes #4012 from Reamer/npe_interpreter_output and squashes the following commits:
b45c0f570 [Philipp Dallig] Use new constructor introduced with ZEPPELIN-5170
---
.../apache/zeppelin/flink/FlinkInterpreterTest.java | 2 +-
.../apache/zeppelin/flink/IPyFlinkInterpreterTest.java | 4 ++--
.../apache/zeppelin/flink/PyFlinkInterpreterTest.java | 2 +-
.../org/apache/zeppelin/flink/SqlInterpreterTest.java | 3 +--
.../jdbc/JDBCInterpreterInterpolationTest.java | 2 +-
.../org/apache/zeppelin/jdbc/JDBCInterpreterTest.java | 18 +++++++++---------
.../apache/zeppelin/kotlin/KotlinInterpreterTest.java | 2 +-
.../org/apache/zeppelin/ksql/KSQLInterpreterTest.java | 2 +-
.../apache/zeppelin/livy/LivySparkSQLInterpreter.java | 2 +-
.../graph/neo4j/Neo4jCypherInterpreterTest.java | 4 ++--
.../zeppelin/python/BasePythonInterpreterTest.java | 2 +-
.../zeppelin/python/PythonCondaInterpreterTest.java | 2 +-
.../zeppelin/python/PythonDockerInterpreterTest.java | 2 +-
.../java/org/apache/zeppelin/r/IRInterpreterTest.java | 2 +-
.../java/org/apache/zeppelin/r/RInterpreterTest.java | 2 +-
.../org/apache/zeppelin/r/ShinyInterpreterTest.java | 2 +-
.../org/apache/zeppelin/shell/BaseInterpreterTest.java | 2 +-
.../apache/zeppelin/spark/IPySparkInterpreterTest.java | 2 +-
.../zeppelin/spark/KotlinSparkInterpreterTest.java | 2 +-
.../spark/PySparkInterpreterMatplotlibTest.java | 2 +-
.../apache/zeppelin/spark/PySparkInterpreterTest.java | 2 +-
.../apache/zeppelin/spark/SparkIRInterpreterTest.java | 3 ++-
.../apache/zeppelin/spark/SparkInterpreterTest.java | 4 ++--
.../apache/zeppelin/spark/SparkRInterpreterTest.java | 6 +++---
.../apache/zeppelin/spark/SparkSqlInterpreterTest.java | 6 +++---
.../apache/zeppelin/submarine/BaseInterpreterTest.java | 2 +-
.../display/angular/AbstractAngularElemTest.scala | 2 +-
.../display/angular/AbstractAngularModelTest.scala | 2 +-
.../apache/zeppelin/helium/ApplicationLoaderTest.java | 2 +-
.../org/apache/zeppelin/jupyter/IPythonKernelTest.java | 2 +-
.../java/org/apache/zeppelin/jupyter/IRKernelTest.java | 2 +-
31 files changed, 47 insertions(+), 47 deletions(-)
diff --git a/flink/interpreter/src/test/java/org/apache/zeppelin/flink/FlinkInterpreterTest.java b/flink/interpreter/src/test/java/org/apache/zeppelin/flink/FlinkInterpreterTest.java
index 37f3309..7a97656 100644
--- a/flink/interpreter/src/test/java/org/apache/zeppelin/flink/FlinkInterpreterTest.java
+++ b/flink/interpreter/src/test/java/org/apache/zeppelin/flink/FlinkInterpreterTest.java
@@ -400,7 +400,7 @@ public class FlinkInterpreterTest {
private InterpreterContext getInterpreterContext() {
InterpreterContext context = InterpreterContext.builder()
.setParagraphId("paragraphId")
- .setInterpreterOut(new InterpreterOutput(null))
+ .setInterpreterOut(new InterpreterOutput())
.setAngularObjectRegistry(angularObjectRegistry)
.setIntpEventClient(mock(RemoteInterpreterEventClient.class))
.build();
diff --git a/flink/interpreter/src/test/java/org/apache/zeppelin/flink/IPyFlinkInterpreterTest.java b/flink/interpreter/src/test/java/org/apache/zeppelin/flink/IPyFlinkInterpreterTest.java
index 200033b..b2a5377 100644
--- a/flink/interpreter/src/test/java/org/apache/zeppelin/flink/IPyFlinkInterpreterTest.java
+++ b/flink/interpreter/src/test/java/org/apache/zeppelin/flink/IPyFlinkInterpreterTest.java
@@ -470,7 +470,7 @@ public class IPyFlinkInterpreterTest extends IPythonInterpreterTest {
InterpreterContext context = InterpreterContext.builder()
.setNoteId("noteId")
.setParagraphId("paragraphId")
- .setInterpreterOut(new InterpreterOutput(null))
+ .setInterpreterOut(new InterpreterOutput())
.setIntpEventClient(mock(RemoteInterpreterEventClient.class))
.setAngularObjectRegistry(angularObjectRegistry)
.build();
@@ -482,7 +482,7 @@ public class IPyFlinkInterpreterTest extends IPythonInterpreterTest {
InterpreterContext context = InterpreterContext.builder()
.setNoteId("noteId")
.setParagraphId("paragraphId")
- .setInterpreterOut(new InterpreterOutput(null))
+ .setInterpreterOut(new InterpreterOutput())
.setAngularObjectRegistry(angularObjectRegistry)
.setIntpEventClient(mock(RemoteInterpreterEventClient.class))
.build();
diff --git a/flink/interpreter/src/test/java/org/apache/zeppelin/flink/PyFlinkInterpreterTest.java b/flink/interpreter/src/test/java/org/apache/zeppelin/flink/PyFlinkInterpreterTest.java
index 6553722..c891ec1 100644
--- a/flink/interpreter/src/test/java/org/apache/zeppelin/flink/PyFlinkInterpreterTest.java
+++ b/flink/interpreter/src/test/java/org/apache/zeppelin/flink/PyFlinkInterpreterTest.java
@@ -133,7 +133,7 @@ public class PyFlinkInterpreterTest extends PythonInterpreterTest {
InterpreterContext context = InterpreterContext.builder()
.setNoteId("noteId")
.setParagraphId("paragraphId")
- .setInterpreterOut(new InterpreterOutput(null))
+ .setInterpreterOut(new InterpreterOutput())
.setAngularObjectRegistry(IPyFlinkInterpreterTest.angularObjectRegistry)
.setIntpEventClient(mock(RemoteInterpreterEventClient.class))
.build();
diff --git a/flink/interpreter/src/test/java/org/apache/zeppelin/flink/SqlInterpreterTest.java b/flink/interpreter/src/test/java/org/apache/zeppelin/flink/SqlInterpreterTest.java
index bee3159..267a363 100644
--- a/flink/interpreter/src/test/java/org/apache/zeppelin/flink/SqlInterpreterTest.java
+++ b/flink/interpreter/src/test/java/org/apache/zeppelin/flink/SqlInterpreterTest.java
@@ -567,10 +567,9 @@ public abstract class SqlInterpreterTest {
protected InterpreterContext getInterpreterContext() {
InterpreterContext context = InterpreterContext.builder()
.setParagraphId("paragraphId")
- .setInterpreterOut(new InterpreterOutput(null))
+ .setInterpreterOut(new InterpreterOutput())
.setAngularObjectRegistry(angularObjectRegistry)
.setIntpEventClient(mock(RemoteInterpreterEventClient.class))
- .setInterpreterOut(new InterpreterOutput(null))
.build();
InterpreterContext.set(context);
return context;
diff --git a/jdbc/src/test/java/org/apache/zeppelin/jdbc/JDBCInterpreterInterpolationTest.java b/jdbc/src/test/java/org/apache/zeppelin/jdbc/JDBCInterpreterInterpolationTest.java
index 0fbc2b5..1374739 100644
--- a/jdbc/src/test/java/org/apache/zeppelin/jdbc/JDBCInterpreterInterpolationTest.java
+++ b/jdbc/src/test/java/org/apache/zeppelin/jdbc/JDBCInterpreterInterpolationTest.java
@@ -196,7 +196,7 @@ public class JDBCInterpreterInterpolationTest extends BasicJDBCTestCaseAdapter {
.setParagraphId("paragraph_1")
.setAuthenticationInfo(new AuthenticationInfo("testUser"))
.setResourcePool(resourcePool)
- .setInterpreterOut(new InterpreterOutput(null))
+ .setInterpreterOut(new InterpreterOutput())
.build();
}
}
diff --git a/jdbc/src/test/java/org/apache/zeppelin/jdbc/JDBCInterpreterTest.java b/jdbc/src/test/java/org/apache/zeppelin/jdbc/JDBCInterpreterTest.java
index 4e1b5b3..5eb3858 100644
--- a/jdbc/src/test/java/org/apache/zeppelin/jdbc/JDBCInterpreterTest.java
+++ b/jdbc/src/test/java/org/apache/zeppelin/jdbc/JDBCInterpreterTest.java
@@ -109,7 +109,7 @@ public class JDBCInterpreterTest extends BasicJDBCTestCaseAdapter {
context = InterpreterContext.builder()
.setAuthenticationInfo(new AuthenticationInfo("testUser"))
.setParagraphId("paragraphId")
- .setInterpreterOut(new InterpreterOutput(null))
+ .setInterpreterOut(new InterpreterOutput())
.build();
}
@@ -546,7 +546,7 @@ public class JDBCInterpreterTest extends BasicJDBCTestCaseAdapter {
// user1 runs default
InterpreterContext context = InterpreterContext.builder()
.setAuthenticationInfo(user1Credential)
- .setInterpreterOut(new InterpreterOutput(null))
+ .setInterpreterOut(new InterpreterOutput())
.setReplName("jdbc")
.build();
jdbc.interpret("", context);
@@ -558,7 +558,7 @@ public class JDBCInterpreterTest extends BasicJDBCTestCaseAdapter {
// user2 run default
context = InterpreterContext.builder()
.setAuthenticationInfo(user2Credential)
- .setInterpreterOut(new InterpreterOutput(null))
+ .setInterpreterOut(new InterpreterOutput())
.setReplName("jdbc")
.build();
jdbc.interpret("", context);
@@ -572,7 +572,7 @@ public class JDBCInterpreterTest extends BasicJDBCTestCaseAdapter {
localProperties.put("db", "hive");
context = InterpreterContext.builder()
.setAuthenticationInfo(user2Credential)
- .setInterpreterOut(new InterpreterOutput(null))
+ .setInterpreterOut(new InterpreterOutput())
.setLocalProperties(localProperties)
.setReplName("jdbc")
.build();
@@ -598,7 +598,7 @@ public class JDBCInterpreterTest extends BasicJDBCTestCaseAdapter {
// user1 runs default
InterpreterContext context = InterpreterContext.builder()
.setAuthenticationInfo(user1Credential)
- .setInterpreterOut(new InterpreterOutput(null))
+ .setInterpreterOut(new InterpreterOutput())
.setReplName("hive")
.build();
jdbc.interpret("", context);
@@ -610,7 +610,7 @@ public class JDBCInterpreterTest extends BasicJDBCTestCaseAdapter {
// user2 run default
context = InterpreterContext.builder()
.setAuthenticationInfo(user2Credential)
- .setInterpreterOut(new InterpreterOutput(null))
+ .setInterpreterOut(new InterpreterOutput())
.setReplName("hive")
.build();
jdbc.interpret("", context);
@@ -690,7 +690,7 @@ public class JDBCInterpreterTest extends BasicJDBCTestCaseAdapter {
localProperties.put("db", "anotherPrefix");
InterpreterContext context = InterpreterContext.builder()
.setAuthenticationInfo(new AuthenticationInfo("testUser"))
- .setInterpreterOut(new InterpreterOutput(null))
+ .setInterpreterOut(new InterpreterOutput())
.setLocalProperties(localProperties)
.build();
jdbcInterpreter.executePrecode(context);
@@ -773,7 +773,7 @@ public class JDBCInterpreterTest extends BasicJDBCTestCaseAdapter {
localProperties.put("db", "anotherPrefix");
InterpreterContext context = InterpreterContext.builder()
.setAuthenticationInfo(new AuthenticationInfo("testUser"))
- .setInterpreterOut(new InterpreterOutput(null))
+ .setInterpreterOut(new InterpreterOutput())
.setLocalProperties(localProperties)
.build();
@@ -822,7 +822,7 @@ public class JDBCInterpreterTest extends BasicJDBCTestCaseAdapter {
return InterpreterContext.builder()
.setAuthenticationInfo(new AuthenticationInfo("testUser"))
.setParagraphId("paragraphId")
- .setInterpreterOut(new InterpreterOutput(null))
+ .setInterpreterOut(new InterpreterOutput())
.build();
}
}
diff --git a/kotlin/src/test/java/org/apache/zeppelin/kotlin/KotlinInterpreterTest.java b/kotlin/src/test/java/org/apache/zeppelin/kotlin/KotlinInterpreterTest.java
index a474b3a..02cdeb7 100644
--- a/kotlin/src/test/java/org/apache/zeppelin/kotlin/KotlinInterpreterTest.java
+++ b/kotlin/src/test/java/org/apache/zeppelin/kotlin/KotlinInterpreterTest.java
@@ -298,7 +298,7 @@ public class KotlinInterpreterTest {
private static InterpreterContext getInterpreterContext() {
output = "";
InterpreterContext context = InterpreterContext.builder()
- .setInterpreterOut(new InterpreterOutput(null))
+ .setInterpreterOut(new InterpreterOutput())
.build();
context.out = new InterpreterOutput(
new InterpreterOutputListener() {
diff --git a/ksql/src/test/java/org/apache/zeppelin/ksql/KSQLInterpreterTest.java b/ksql/src/test/java/org/apache/zeppelin/ksql/KSQLInterpreterTest.java
index b9520fb..93bba35 100644
--- a/ksql/src/test/java/org/apache/zeppelin/ksql/KSQLInterpreterTest.java
+++ b/ksql/src/test/java/org/apache/zeppelin/ksql/KSQLInterpreterTest.java
@@ -53,7 +53,7 @@ public class KSQLInterpreterTest {
@Before
public void setUpZeppelin() throws IOException {
context = InterpreterContext.builder()
- .setInterpreterOut(new InterpreterOutput(null))
+ .setInterpreterOut(new InterpreterOutput())
.setParagraphId("ksql-test")
.build();
}
diff --git a/livy/src/main/java/org/apache/zeppelin/livy/LivySparkSQLInterpreter.java b/livy/src/main/java/org/apache/zeppelin/livy/LivySparkSQLInterpreter.java
index a3b0da2..50b2f92 100644
--- a/livy/src/main/java/org/apache/zeppelin/livy/LivySparkSQLInterpreter.java
+++ b/livy/src/main/java/org/apache/zeppelin/livy/LivySparkSQLInterpreter.java
@@ -72,7 +72,7 @@ public class LivySparkSQLInterpreter extends BaseLivyInterpreter {
// to judge whether it is using spark2.
try {
InterpreterContext context = InterpreterContext.builder()
- .setInterpreterOut(new InterpreterOutput(null))
+ .setInterpreterOut(new InterpreterOutput())
.build();
InterpreterResult result = sparkInterpreter.interpret("spark", context);
if (result.code() == InterpreterResult.Code.SUCCESS &&
diff --git a/neo4j/src/test/java/org/apache/zeppelin/graph/neo4j/Neo4jCypherInterpreterTest.java b/neo4j/src/test/java/org/apache/zeppelin/graph/neo4j/Neo4jCypherInterpreterTest.java
index 4471993..208d3d6 100644
--- a/neo4j/src/test/java/org/apache/zeppelin/graph/neo4j/Neo4jCypherInterpreterTest.java
+++ b/neo4j/src/test/java/org/apache/zeppelin/graph/neo4j/Neo4jCypherInterpreterTest.java
@@ -92,7 +92,7 @@ public class Neo4jCypherInterpreterTest {
p.setProperty(Neo4jCypherInterpreter.NEO4J_MULTI_STATEMENT, "false");
interpreter = new Neo4jCypherInterpreter(p);
context = InterpreterContext.builder()
- .setInterpreterOut(new InterpreterOutput(null))
+ .setInterpreterOut(new InterpreterOutput())
.build();
}
@@ -334,7 +334,7 @@ public class Neo4jCypherInterpreterTest {
p.setProperty(Neo4jCypherInterpreter.NEO4J_MULTI_STATEMENT, "true");
Neo4jCypherInterpreter multiLineInterpreter = new Neo4jCypherInterpreter(p);
context = InterpreterContext.builder()
- .setInterpreterOut(new InterpreterOutput(null))
+ .setInterpreterOut(new InterpreterOutput())
.build();
InterpreterResult result = multiLineInterpreter.interpret("CREATE (n:Node{name: ';'});" +
"\nRETURN 1 AS val;", context);
diff --git a/python/src/test/java/org/apache/zeppelin/python/BasePythonInterpreterTest.java b/python/src/test/java/org/apache/zeppelin/python/BasePythonInterpreterTest.java
index 75213fc..53bc364 100644
--- a/python/src/test/java/org/apache/zeppelin/python/BasePythonInterpreterTest.java
+++ b/python/src/test/java/org/apache/zeppelin/python/BasePythonInterpreterTest.java
@@ -403,7 +403,7 @@ public abstract class BasePythonInterpreterTest extends ConcurrentTestCase {
return InterpreterContext.builder()
.setNoteId("noteId")
.setParagraphId("paragraphId")
- .setInterpreterOut(new InterpreterOutput(null))
+ .setInterpreterOut(new InterpreterOutput())
.setIntpEventClient(mock(RemoteInterpreterEventClient.class))
.build();
}
diff --git a/python/src/test/java/org/apache/zeppelin/python/PythonCondaInterpreterTest.java b/python/src/test/java/org/apache/zeppelin/python/PythonCondaInterpreterTest.java
index a2cdac8..95302b6 100644
--- a/python/src/test/java/org/apache/zeppelin/python/PythonCondaInterpreterTest.java
+++ b/python/src/test/java/org/apache/zeppelin/python/PythonCondaInterpreterTest.java
@@ -134,7 +134,7 @@ public class PythonCondaInterpreterTest {
private InterpreterContext getInterpreterContext() {
return InterpreterContext.builder()
- .setInterpreterOut(new InterpreterOutput(null))
+ .setInterpreterOut(new InterpreterOutput())
.build();
}
diff --git a/python/src/test/java/org/apache/zeppelin/python/PythonDockerInterpreterTest.java b/python/src/test/java/org/apache/zeppelin/python/PythonDockerInterpreterTest.java
index 04bb414..12c1490 100644
--- a/python/src/test/java/org/apache/zeppelin/python/PythonDockerInterpreterTest.java
+++ b/python/src/test/java/org/apache/zeppelin/python/PythonDockerInterpreterTest.java
@@ -78,7 +78,7 @@ public class PythonDockerInterpreterTest {
private InterpreterContext getInterpreterContext() {
return InterpreterContext.builder()
- .setInterpreterOut(new InterpreterOutput(null))
+ .setInterpreterOut(new InterpreterOutput())
.build();
}
}
diff --git a/rlang/src/test/java/org/apache/zeppelin/r/IRInterpreterTest.java b/rlang/src/test/java/org/apache/zeppelin/r/IRInterpreterTest.java
index 8305281..44a45e4 100644
--- a/rlang/src/test/java/org/apache/zeppelin/r/IRInterpreterTest.java
+++ b/rlang/src/test/java/org/apache/zeppelin/r/IRInterpreterTest.java
@@ -38,7 +38,7 @@ public class IRInterpreterTest extends IRKernelTest {
InterpreterContext context = InterpreterContext.builder()
.setNoteId("note_1")
.setParagraphId("paragraph_1")
- .setInterpreterOut(new InterpreterOutput(null))
+ .setInterpreterOut(new InterpreterOutput())
.setLocalProperties(new HashMap<>())
.build();
return context;
diff --git a/rlang/src/test/java/org/apache/zeppelin/r/RInterpreterTest.java b/rlang/src/test/java/org/apache/zeppelin/r/RInterpreterTest.java
index 1652858..90b4507 100644
--- a/rlang/src/test/java/org/apache/zeppelin/r/RInterpreterTest.java
+++ b/rlang/src/test/java/org/apache/zeppelin/r/RInterpreterTest.java
@@ -137,7 +137,7 @@ public class RInterpreterTest {
InterpreterContext context = InterpreterContext.builder()
.setNoteId("note_1")
.setParagraphId("paragraph_1")
- .setInterpreterOut(new InterpreterOutput(null))
+ .setInterpreterOut(new InterpreterOutput())
.setLocalProperties(new HashMap<>())
.build();
return context;
diff --git a/rlang/src/test/java/org/apache/zeppelin/r/ShinyInterpreterTest.java b/rlang/src/test/java/org/apache/zeppelin/r/ShinyInterpreterTest.java
index f9c33e8..91d026e 100644
--- a/rlang/src/test/java/org/apache/zeppelin/r/ShinyInterpreterTest.java
+++ b/rlang/src/test/java/org/apache/zeppelin/r/ShinyInterpreterTest.java
@@ -240,7 +240,7 @@ public class ShinyInterpreterTest {
InterpreterContext context = InterpreterContext.builder()
.setNoteId("note_1")
.setParagraphId("paragraph_1")
- .setInterpreterOut(new InterpreterOutput(null))
+ .setInterpreterOut(new InterpreterOutput())
.setLocalProperties(new HashMap<>())
.setInterpreterClassName(ShinyInterpreter.class.getName())
.setIntpEventClient(mock(RemoteInterpreterEventClient.class))
diff --git a/shell/src/test/java/org/apache/zeppelin/shell/BaseInterpreterTest.java b/shell/src/test/java/org/apache/zeppelin/shell/BaseInterpreterTest.java
index 76c18f1..a8997e3 100644
--- a/shell/src/test/java/org/apache/zeppelin/shell/BaseInterpreterTest.java
+++ b/shell/src/test/java/org/apache/zeppelin/shell/BaseInterpreterTest.java
@@ -74,7 +74,7 @@ public abstract class BaseInterpreterTest {
.setParagraphId("paragraphId")
.setAuthenticationInfo(authenticationInfo)
.setAngularObjectRegistry(registry)
- .setInterpreterOut(new InterpreterOutput(null))
+ .setInterpreterOut(new InterpreterOutput())
.setIntpEventClient(mock(RemoteInterpreterEventClient.class))
.build();
}
diff --git a/spark/interpreter/src/test/java/org/apache/zeppelin/spark/IPySparkInterpreterTest.java b/spark/interpreter/src/test/java/org/apache/zeppelin/spark/IPySparkInterpreterTest.java
index 0c160b3..101b742 100644
--- a/spark/interpreter/src/test/java/org/apache/zeppelin/spark/IPySparkInterpreterTest.java
+++ b/spark/interpreter/src/test/java/org/apache/zeppelin/spark/IPySparkInterpreterTest.java
@@ -272,7 +272,7 @@ public class IPySparkInterpreterTest extends IPythonInterpreterTest {
.setNoteId("noteId")
.setParagraphId("paragraphId")
.setIntpEventClient(mockRemoteEventClient)
- .setInterpreterOut(new InterpreterOutput(null))
+ .setInterpreterOut(new InterpreterOutput())
.build();
}
}
diff --git a/spark/interpreter/src/test/java/org/apache/zeppelin/spark/KotlinSparkInterpreterTest.java b/spark/interpreter/src/test/java/org/apache/zeppelin/spark/KotlinSparkInterpreterTest.java
index 536142e..1c14c09 100644
--- a/spark/interpreter/src/test/java/org/apache/zeppelin/spark/KotlinSparkInterpreterTest.java
+++ b/spark/interpreter/src/test/java/org/apache/zeppelin/spark/KotlinSparkInterpreterTest.java
@@ -103,7 +103,7 @@ public class KotlinSparkInterpreterTest {
.setParagraphTitle("title")
.setAngularObjectRegistry(new AngularObjectRegistry(intpGroup.getId(), null))
.setResourcePool(new LocalResourcePool("id"))
- .setInterpreterOut(new InterpreterOutput(null))
+ .setInterpreterOut(new InterpreterOutput())
.setIntpEventClient(mock(RemoteInterpreterEventClient.class))
.build();
context.out = new InterpreterOutput(
diff --git a/spark/interpreter/src/test/java/org/apache/zeppelin/spark/PySparkInterpreterMatplotlibTest.java b/spark/interpreter/src/test/java/org/apache/zeppelin/spark/PySparkInterpreterMatplotlibTest.java
index a9aa283..24e8afe 100644
--- a/spark/interpreter/src/test/java/org/apache/zeppelin/spark/PySparkInterpreterMatplotlibTest.java
+++ b/spark/interpreter/src/test/java/org/apache/zeppelin/spark/PySparkInterpreterMatplotlibTest.java
@@ -126,7 +126,7 @@ public class PySparkInterpreterMatplotlibTest {
intpGroup.put("note", new LinkedList<Interpreter>());
context = InterpreterContext.builder()
.setNoteId("note")
- .setInterpreterOut(new InterpreterOutput(null))
+ .setInterpreterOut(new InterpreterOutput())
.setIntpEventClient(mock(RemoteInterpreterEventClient.class))
.setAngularObjectRegistry(new AngularObjectRegistry(intpGroup.getId(), null))
.build();
diff --git a/spark/interpreter/src/test/java/org/apache/zeppelin/spark/PySparkInterpreterTest.java b/spark/interpreter/src/test/java/org/apache/zeppelin/spark/PySparkInterpreterTest.java
index ab24315..a17dc4e 100644
--- a/spark/interpreter/src/test/java/org/apache/zeppelin/spark/PySparkInterpreterTest.java
+++ b/spark/interpreter/src/test/java/org/apache/zeppelin/spark/PySparkInterpreterTest.java
@@ -62,7 +62,7 @@ public class PySparkInterpreterTest extends PythonInterpreterTest {
intpGroup.put("note", new LinkedList<Interpreter>());
InterpreterContext context = InterpreterContext.builder()
- .setInterpreterOut(new InterpreterOutput(null))
+ .setInterpreterOut(new InterpreterOutput())
.setIntpEventClient(mockRemoteEventClient)
.build();
InterpreterContext.set(context);
diff --git a/spark/interpreter/src/test/java/org/apache/zeppelin/spark/SparkIRInterpreterTest.java b/spark/interpreter/src/test/java/org/apache/zeppelin/spark/SparkIRInterpreterTest.java
index 11f5594..12cd6b0 100644
--- a/spark/interpreter/src/test/java/org/apache/zeppelin/spark/SparkIRInterpreterTest.java
+++ b/spark/interpreter/src/test/java/org/apache/zeppelin/spark/SparkIRInterpreterTest.java
@@ -54,6 +54,7 @@ public class SparkIRInterpreterTest extends IRInterpreterTest {
return new SparkIRInterpreter(properties);
}
+ @Override
@Before
public void setUp() throws InterpreterException {
Properties properties = new Properties();
@@ -144,7 +145,7 @@ public class SparkIRInterpreterTest extends IRInterpreterTest {
InterpreterContext context = InterpreterContext.builder()
.setNoteId("note_1")
.setParagraphId("paragraph_1")
- .setInterpreterOut(new InterpreterOutput(null))
+ .setInterpreterOut(new InterpreterOutput())
.setLocalProperties(new HashMap<>())
.setIntpEventClient(mockRemoteIntpEventClient)
.build();
diff --git a/spark/interpreter/src/test/java/org/apache/zeppelin/spark/SparkInterpreterTest.java b/spark/interpreter/src/test/java/org/apache/zeppelin/spark/SparkInterpreterTest.java
index 9b42f6a..c613fcf 100644
--- a/spark/interpreter/src/test/java/org/apache/zeppelin/spark/SparkInterpreterTest.java
+++ b/spark/interpreter/src/test/java/org/apache/zeppelin/spark/SparkInterpreterTest.java
@@ -78,7 +78,7 @@ public class SparkInterpreterTest {
properties.setProperty("zeppelin.spark.deprecatedMsg.show", "false");
InterpreterContext context = InterpreterContext.builder()
- .setInterpreterOut(new InterpreterOutput(null))
+ .setInterpreterOut(new InterpreterOutput())
.setIntpEventClient(mockRemoteEventClient)
.setAngularObjectRegistry(new AngularObjectRegistry("spark", null))
.build();
@@ -596,7 +596,7 @@ public class SparkInterpreterTest {
private InterpreterContext getInterpreterContext() {
output = "";
InterpreterContext context = InterpreterContext.builder()
- .setInterpreterOut(new InterpreterOutput(null))
+ .setInterpreterOut(new InterpreterOutput())
.setIntpEventClient(mockRemoteEventClient)
.setAngularObjectRegistry(new AngularObjectRegistry("spark", null))
.build();
diff --git a/spark/interpreter/src/test/java/org/apache/zeppelin/spark/SparkRInterpreterTest.java b/spark/interpreter/src/test/java/org/apache/zeppelin/spark/SparkRInterpreterTest.java
index f87caa0..8a54f69 100644
--- a/spark/interpreter/src/test/java/org/apache/zeppelin/spark/SparkRInterpreterTest.java
+++ b/spark/interpreter/src/test/java/org/apache/zeppelin/spark/SparkRInterpreterTest.java
@@ -57,7 +57,7 @@ public class SparkRInterpreterTest {
properties.setProperty("zeppelin.R.knitr", "true");
properties.setProperty("spark.r.backendConnectionTimeout", "10");
properties.setProperty("zeppelin.spark.deprecatedMsg.show", "false");
-
+
InterpreterContext context = getInterpreterContext();
InterpreterContext.set(context);
sparkRInterpreter = new SparkRInterpreter(properties);
@@ -157,7 +157,7 @@ public class SparkRInterpreterTest {
properties.setProperty("zeppelin.R.cmd", "invalid_r");
properties.setProperty(SparkStringConstants.MASTER_PROP_NAME, "local");
properties.setProperty(SparkStringConstants.APP_NAME_PROP_NAME, "test");
-
+
InterpreterGroup interpreterGroup = new InterpreterGroup();
Interpreter sparkRInterpreter = new LazyOpenInterpreter(new SparkRInterpreter(properties));
Interpreter sparkInterpreter = new LazyOpenInterpreter(new SparkInterpreter(properties));
@@ -183,7 +183,7 @@ public class SparkRInterpreterTest {
.setNoteId("note_1")
.setParagraphId("paragraph_1")
.setIntpEventClient(mockRemoteIntpEventClient)
- .setInterpreterOut(new InterpreterOutput(null))
+ .setInterpreterOut(new InterpreterOutput())
.setLocalProperties(new HashMap<>())
.build();
return context;
diff --git a/spark/interpreter/src/test/java/org/apache/zeppelin/spark/SparkSqlInterpreterTest.java b/spark/interpreter/src/test/java/org/apache/zeppelin/spark/SparkSqlInterpreterTest.java
index 843ee77..8c01130 100644
--- a/spark/interpreter/src/test/java/org/apache/zeppelin/spark/SparkSqlInterpreterTest.java
+++ b/spark/interpreter/src/test/java/org/apache/zeppelin/spark/SparkSqlInterpreterTest.java
@@ -73,7 +73,7 @@ public class SparkSqlInterpreterTest {
.setParagraphTitle("title")
.setAngularObjectRegistry(new AngularObjectRegistry(intpGroup.getId(), null))
.setResourcePool(new LocalResourcePool("id"))
- .setInterpreterOut(new InterpreterOutput(null))
+ .setInterpreterOut(new InterpreterOutput())
.setIntpEventClient(mock(RemoteInterpreterEventClient.class))
.build();
InterpreterContext.set(context);
@@ -188,7 +188,7 @@ public class SparkSqlInterpreterTest {
.setParagraphTitle("title")
.setAngularObjectRegistry(new AngularObjectRegistry(intpGroup.getId(), null))
.setResourcePool(new LocalResourcePool("id"))
- .setInterpreterOut(new InterpreterOutput(null))
+ .setInterpreterOut(new InterpreterOutput())
.setIntpEventClient(mock(RemoteInterpreterEventClient.class))
.build();
context.getLocalProperties().put("template", "Total count: <h1>{0}</h1>, Total age: <h1>{1}</h1>");
@@ -224,7 +224,7 @@ public class SparkSqlInterpreterTest {
if (!sparkInterpreter.getSparkVersion().isSpark1()) {
assertTrue(context.out.toString(), context.out.toInterpreterResultMessage().get(1).getData().contains("mismatched input"));
}
-
+
// One correct sql + One invalid sql + One valid sql (skipped)
ret = sqlInterpreter.interpret("select * from gr;invalid_sql; select count(1) from gr", context);
assertEquals(InterpreterResult.Code.ERROR, ret.code());
diff --git a/submarine/src/test/java/org/apache/zeppelin/submarine/BaseInterpreterTest.java b/submarine/src/test/java/org/apache/zeppelin/submarine/BaseInterpreterTest.java
index 4cc6d3b..3cb1b2f 100644
--- a/submarine/src/test/java/org/apache/zeppelin/submarine/BaseInterpreterTest.java
+++ b/submarine/src/test/java/org/apache/zeppelin/submarine/BaseInterpreterTest.java
@@ -74,7 +74,7 @@ public abstract class BaseInterpreterTest {
.setParagraphId("paragraphId")
.setAuthenticationInfo(authenticationInfo)
.setAngularObjectRegistry(registry)
- .setInterpreterOut(new InterpreterOutput(null))
+ .setInterpreterOut(new InterpreterOutput())
.setIntpEventClient(mock(RemoteInterpreterEventClient.class))
.build();
}
diff --git a/zeppelin-display/src/test/scala/org/apache/zeppelin/display/angular/AbstractAngularElemTest.scala b/zeppelin-display/src/test/scala/org/apache/zeppelin/display/angular/AbstractAngularElemTest.scala
index 0567647..d1b2aea 100644
--- a/zeppelin-display/src/test/scala/org/apache/zeppelin/display/angular/AbstractAngularElemTest.scala
+++ b/zeppelin-display/src/test/scala/org/apache/zeppelin/display/angular/AbstractAngularElemTest.scala
@@ -37,7 +37,7 @@ trait AbstractAngularElemTest
val context = InterpreterContext.builder
.setNoteId("noteId")
.setAngularObjectRegistry(new AngularObjectRegistry(intpGroup.getId(), null))
- .setInterpreterOut(new InterpreterOutput(null))
+ .setInterpreterOut(new InterpreterOutput())
.build()
InterpreterContext.set(context)
diff --git a/zeppelin-display/src/test/scala/org/apache/zeppelin/display/angular/AbstractAngularModelTest.scala b/zeppelin-display/src/test/scala/org/apache/zeppelin/display/angular/AbstractAngularModelTest.scala
index 477e249..4f3193c 100644
--- a/zeppelin-display/src/test/scala/org/apache/zeppelin/display/angular/AbstractAngularModelTest.scala
+++ b/zeppelin-display/src/test/scala/org/apache/zeppelin/display/angular/AbstractAngularModelTest.scala
@@ -32,7 +32,7 @@ with BeforeAndAfter with BeforeAndAfterEach with Eventually with Matchers {
val context = InterpreterContext.builder
.setNoteId("noteId")
.setAngularObjectRegistry(new AngularObjectRegistry(intpGroup.getId(), null))
- .setInterpreterOut(new InterpreterOutput(null))
+ .setInterpreterOut(new InterpreterOutput())
.build()
InterpreterContext.set(context)
diff --git a/zeppelin-interpreter/src/test/java/org/apache/zeppelin/helium/ApplicationLoaderTest.java b/zeppelin-interpreter/src/test/java/org/apache/zeppelin/helium/ApplicationLoaderTest.java
index 490c911..0cbfc90 100644
--- a/zeppelin-interpreter/src/test/java/org/apache/zeppelin/helium/ApplicationLoaderTest.java
+++ b/zeppelin-interpreter/src/test/java/org/apache/zeppelin/helium/ApplicationLoaderTest.java
@@ -92,7 +92,7 @@ public class ApplicationLoaderTest {
paragraphId,
appInstanceId,
null,
- new InterpreterOutput(null));
+ new InterpreterOutput());
return context1;
}
}
diff --git a/zeppelin-jupyter-interpreter/src/test/java/org/apache/zeppelin/jupyter/IPythonKernelTest.java b/zeppelin-jupyter-interpreter/src/test/java/org/apache/zeppelin/jupyter/IPythonKernelTest.java
index af48f87..bc27ee2 100644
--- a/zeppelin-jupyter-interpreter/src/test/java/org/apache/zeppelin/jupyter/IPythonKernelTest.java
+++ b/zeppelin-jupyter-interpreter/src/test/java/org/apache/zeppelin/jupyter/IPythonKernelTest.java
@@ -300,7 +300,7 @@ public class IPythonKernelTest {
return InterpreterContext.builder()
.setNoteId("noteId")
.setParagraphId("paragraphId")
- .setInterpreterOut(new InterpreterOutput(null))
+ .setInterpreterOut(new InterpreterOutput())
.setIntpEventClient(mock(RemoteInterpreterEventClient.class))
.setLocalProperties(localProperties)
.setResourcePool(resourcePool)
diff --git a/zeppelin-jupyter-interpreter/src/test/java/org/apache/zeppelin/jupyter/IRKernelTest.java b/zeppelin-jupyter-interpreter/src/test/java/org/apache/zeppelin/jupyter/IRKernelTest.java
index 8be3507..e1ba78e 100644
--- a/zeppelin-jupyter-interpreter/src/test/java/org/apache/zeppelin/jupyter/IRKernelTest.java
+++ b/zeppelin-jupyter-interpreter/src/test/java/org/apache/zeppelin/jupyter/IRKernelTest.java
@@ -152,7 +152,7 @@ public class IRKernelTest {
InterpreterContext context = InterpreterContext.builder()
.setNoteId("note_1")
.setParagraphId("paragraph_1")
- .setInterpreterOut(new InterpreterOutput(null))
+ .setInterpreterOut(new InterpreterOutput())
.setLocalProperties(localProperties)
.build();
return context;