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/08/09 07:40:02 UTC
zeppelin git commit: [HOTIFX] Fix build of master
Repository: zeppelin
Updated Branches:
refs/heads/master b89666374 -> 994acfeb7
[HOTIFX] Fix build of master
(cherry picked from commit 0c712a49c49e22b731d4c0fbf70c3bd30ab5c7eb)
Project: http://git-wip-us.apache.org/repos/asf/zeppelin/repo
Commit: http://git-wip-us.apache.org/repos/asf/zeppelin/commit/994acfeb
Tree: http://git-wip-us.apache.org/repos/asf/zeppelin/tree/994acfeb
Diff: http://git-wip-us.apache.org/repos/asf/zeppelin/diff/994acfeb
Branch: refs/heads/master
Commit: 994acfeb73319dfa9c5b4b18dba94e7469aefa40
Parents: b896663
Author: Jeff Zhang <zj...@apache.org>
Authored: Thu Aug 9 13:51:58 2018 +0800
Committer: Jeff Zhang <zj...@apache.org>
Committed: Thu Aug 9 15:39:55 2018 +0800
----------------------------------------------------------------------
.../org/apache/zeppelin/interpreter/FlinkIntegrationTest.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/zeppelin/blob/994acfeb/zeppelin-zengine/src/test/java/org/apache/zeppelin/interpreter/FlinkIntegrationTest.java
----------------------------------------------------------------------
diff --git a/zeppelin-zengine/src/test/java/org/apache/zeppelin/interpreter/FlinkIntegrationTest.java b/zeppelin-zengine/src/test/java/org/apache/zeppelin/interpreter/FlinkIntegrationTest.java
index f3a154e..57aacdb 100644
--- a/zeppelin-zengine/src/test/java/org/apache/zeppelin/interpreter/FlinkIntegrationTest.java
+++ b/zeppelin-zengine/src/test/java/org/apache/zeppelin/interpreter/FlinkIntegrationTest.java
@@ -70,8 +70,7 @@ public class FlinkIntegrationTest {
private void testInterpreterBasics() throws IOException, InterpreterException {
// test FlinkInterpreter
- interpreterSettingManager.setInterpreterBinding("user1", "note1", interpreterSettingManager.getInterpreterSettingIds());
- Interpreter flinkInterpreter = interpreterFactory.getInterpreter("user1", "note1", "flink");
+ Interpreter flinkInterpreter = interpreterFactory.getInterpreter("user1", "note1", "flink", "flink");
InterpreterContext context = new InterpreterContext.Builder().setNoteId("note1").setParagraphId("paragraph_1").build();
InterpreterResult interpreterResult = flinkInterpreter.interpret("1+1", context);