Repository: zeppelin Updated Branches: refs/heads/master 2a33fd379 -> 50cfabdf9
http://git-wip-us.apache.org/repos/asf/zeppelin/blob/50cfabdf/zeppelin-zengine/src/test/java/org/apache/zeppelin/interpreter/remote/RemoteInterpreterTest.java ---------------------------------------------------------------------- diff --git a/zeppelin-zengine/src/test/java/org/apache/zeppelin/interpreter/remote/RemoteInterpreterTest.java b/zeppelin-zengine/src/test/java/org/apache/zeppelin/interpreter/remote/RemoteInterpreterTest.java index c268c81..7f9978a 100644 --- a/zeppelin-zengine/src/test/java/org/apache/zeppelin/interpreter/remote/RemoteInterpreterTest.java +++ b/zeppelin-zengine/src/test/java/org/apache/zeppelin/interpreter/remote/RemoteInterpreterTest.java @@ -94,7 +94,7 @@ public class RemoteInterpreterTest { RemoteInterpreter remoteInterpreter2 = (RemoteInterpreter) interpreter2; InterpreterContext context1 = new InterpreterContext("noteId", "paragraphId", "repl", - "title", "text", AuthenticationInfo.ANONYMOUS, new HashMap<String, Object>(), new GUI(), + "title", "text", AuthenticationInfo.ANONYMOUS, new HashMap<String, Object>(), new GUI(), new GUI(), null, null, new ArrayList<InterpreterContextRunner>(), null); assertEquals("hello", remoteInterpreter1.interpret("hello", context1).message().get(0).getData()); assertEquals(Interpreter.FormType.NATIVE, interpreter1.getFormType()); @@ -137,7 +137,7 @@ public class RemoteInterpreterTest { RemoteInterpreter remoteInterpreter2 = (RemoteInterpreter) interpreter2; InterpreterContext context1 = new InterpreterContext("noteId", "paragraphId", "repl", - "title", "text", AuthenticationInfo.ANONYMOUS, new HashMap<String, Object>(), new GUI(), + "title", "text", AuthenticationInfo.ANONYMOUS, new HashMap<String, Object>(), new GUI(), new GUI(), null, null, new ArrayList<InterpreterContextRunner>(), null); assertEquals("hello", remoteInterpreter1.interpret("hello", context1).message().get(0).getData()); assertEquals("hello", remoteInterpreter2.interpret("hello", context1).message().get(0).getData()); @@ -183,7 +183,7 @@ public class RemoteInterpreterTest { RemoteInterpreter remoteInterpreter2 = (RemoteInterpreter) interpreter2; InterpreterContext context1 = new InterpreterContext("noteId", "paragraphId", "repl", - "title", "text", AuthenticationInfo.ANONYMOUS, new HashMap<String, Object>(), new GUI(), + "title", "text", AuthenticationInfo.ANONYMOUS, new HashMap<String, Object>(), new GUI(), new GUI(), null, null, new ArrayList<InterpreterContextRunner>(), null); assertEquals("hello", remoteInterpreter1.interpret("hello", context1).message().get(0).getData()); assertEquals("hello", remoteInterpreter2.interpret("hello", context1).message().get(0).getData()); @@ -224,7 +224,7 @@ public class RemoteInterpreterTest { interpreterSetting.setProperty("zeppelin.SleepInterpreter.precode", "fail test"); Interpreter interpreter1 = interpreterSetting.getInterpreter("user1", "note1", "sleep"); InterpreterContext context1 = new InterpreterContext("noteId", "paragraphId", "repl", - "title", "text", AuthenticationInfo.ANONYMOUS, new HashMap<String, Object>(), new GUI(), + "title", "text", AuthenticationInfo.ANONYMOUS, new HashMap<String, Object>(), new GUI(), new GUI(), null, null, new ArrayList<InterpreterContextRunner>(), null); assertEquals(Code.ERROR, interpreter1.interpret("10", context1).code()); } @@ -235,7 +235,7 @@ public class RemoteInterpreterTest { interpreterSetting.setProperty("zeppelin.SleepInterpreter.precode", "1"); Interpreter interpreter1 = interpreterSetting.getInterpreter("user1", "note1", "sleep"); InterpreterContext context1 = new InterpreterContext("noteId", "paragraphId", "repl", - "title", "text", AuthenticationInfo.ANONYMOUS, new HashMap<String, Object>(), new GUI(), + "title", "text", AuthenticationInfo.ANONYMOUS, new HashMap<String, Object>(), new GUI(), new GUI(), null, null, new ArrayList<InterpreterContextRunner>(), null); assertEquals(Code.SUCCESS, interpreter1.interpret("10", context1).code()); } @@ -250,7 +250,7 @@ public class RemoteInterpreterTest { RemoteInterpreter remoteInterpreter1 = (RemoteInterpreter) interpreter1; InterpreterContext context1 = new InterpreterContext("noteId", "paragraphId", "repl", - "title", "text", AuthenticationInfo.ANONYMOUS, new HashMap<String, Object>(), new GUI(), + "title", "text", AuthenticationInfo.ANONYMOUS, new HashMap<String, Object>(), new GUI(), new GUI(), null, null, new ArrayList<InterpreterContextRunner>(), null); assertEquals(Code.ERROR, remoteInterpreter1.interpret("hello", context1).code()); } @@ -262,7 +262,7 @@ public class RemoteInterpreterTest { final Interpreter interpreter1 = interpreterSetting.getInterpreter("user1", "note1", "sleep"); final InterpreterContext context1 = new InterpreterContext("noteId", "paragraphId", "repl", - "title", "text", AuthenticationInfo.ANONYMOUS, new HashMap<String, Object>(), new GUI(), + "title", "text", AuthenticationInfo.ANONYMOUS, new HashMap<String, Object>(), new GUI(), new GUI(), null, null, new ArrayList<InterpreterContextRunner>(), null); // run this dummy interpret method first to launch the RemoteInterpreterProcess to avoid the // time overhead of launching the process. @@ -305,7 +305,7 @@ public class RemoteInterpreterTest { final Interpreter interpreter1 = interpreterSetting.getInterpreter("user1", "note1", "sleep"); final InterpreterContext context1 = new InterpreterContext("noteId", "paragraphId", "repl", - "title", "text", AuthenticationInfo.ANONYMOUS, new HashMap<String, Object>(), new GUI(), + "title", "text", AuthenticationInfo.ANONYMOUS, new HashMap<String, Object>(), new GUI(), new GUI(), null, null, new ArrayList<InterpreterContextRunner>(), null); // run this dummy interpret method first to launch the RemoteInterpreterProcess to avoid the @@ -378,7 +378,7 @@ public class RemoteInterpreterTest { interpreter.getInterpreterGroup().setAngularObjectRegistry(registry); final InterpreterContext context = new InterpreterContext("noteId", "paragraphId", "repl", - "title", "text", AuthenticationInfo.ANONYMOUS, new HashMap<String, Object>(), new GUI(), + "title", "text", AuthenticationInfo.ANONYMOUS, new HashMap<String, Object>(), new GUI(), new GUI(), null, null, new ArrayList<InterpreterContextRunner>(), null); InterpreterResult result = interpreter.interpret("dummy", context); @@ -405,7 +405,7 @@ public class RemoteInterpreterTest { final Interpreter interpreter1 = interpreterSetting.getInterpreter("user1", "note1", "get"); final InterpreterContext context1 = new InterpreterContext("noteId", "paragraphId", "repl", - "title", "text", AuthenticationInfo.ANONYMOUS, new HashMap<String, Object>(), new GUI(), + "title", "text", AuthenticationInfo.ANONYMOUS, new HashMap<String, Object>(), new GUI(), new GUI(), null, null, new ArrayList<InterpreterContextRunner>(), null); assertEquals("VALUE_1", interpreter1.interpret("getEnv ENV_1", context1).message().get(0).getData()); @@ -431,7 +431,7 @@ public class RemoteInterpreterTest { Map<String, Input> expected = new LinkedHashMap<>(gui.getForms()); Interpreter interpreter = interpreterSetting.getDefaultInterpreter("user1", "note1"); InterpreterContext context = new InterpreterContext("noteId", "paragraphId", "repl", null, - null, AuthenticationInfo.ANONYMOUS, new HashMap<String, Object>(), gui, + null, AuthenticationInfo.ANONYMOUS, new HashMap<String, Object>(), gui, new GUI(), null, null, new ArrayList<InterpreterContextRunner>(), null); interpreter.interpret("text", context); http://git-wip-us.apache.org/repos/asf/zeppelin/blob/50cfabdf/zeppelin-zengine/src/test/java/org/apache/zeppelin/resource/DistributedResourcePoolTest.java ---------------------------------------------------------------------- diff --git a/zeppelin-zengine/src/test/java/org/apache/zeppelin/resource/DistributedResourcePoolTest.java b/zeppelin-zengine/src/test/java/org/apache/zeppelin/resource/DistributedResourcePoolTest.java index c7ccd46..6f7c197 100644 --- a/zeppelin-zengine/src/test/java/org/apache/zeppelin/resource/DistributedResourcePoolTest.java +++ b/zeppelin-zengine/src/test/java/org/apache/zeppelin/resource/DistributedResourcePoolTest.java @@ -61,6 +61,7 @@ public class DistributedResourcePoolTest extends AbstractInterpreterTest { new AuthenticationInfo(), new HashMap<String, Object>(), new GUI(), + new GUI(), null, null, new LinkedList<InterpreterContextRunner>(), http://git-wip-us.apache.org/repos/asf/zeppelin/blob/50cfabdf/zeppelin-zengine/src/test/java/org/apache/zeppelin/scheduler/RemoteSchedulerTest.java ---------------------------------------------------------------------- diff --git a/zeppelin-zengine/src/test/java/org/apache/zeppelin/scheduler/RemoteSchedulerTest.java b/zeppelin-zengine/src/test/java/org/apache/zeppelin/scheduler/RemoteSchedulerTest.java index e43a39d..1253789 100644 --- a/zeppelin-zengine/src/test/java/org/apache/zeppelin/scheduler/RemoteSchedulerTest.java +++ b/zeppelin-zengine/src/test/java/org/apache/zeppelin/scheduler/RemoteSchedulerTest.java @@ -121,6 +121,7 @@ public class RemoteSchedulerTest implements RemoteInterpreterProcessListener { new AuthenticationInfo(), new HashMap<String, Object>(), new GUI(), + new GUI(), null, new LocalResourcePool("pool1"), new LinkedList<InterpreterContextRunner>(), null)); @@ -182,6 +183,7 @@ public class RemoteSchedulerTest implements RemoteInterpreterProcessListener { new AuthenticationInfo(), new HashMap<String, Object>(), new GUI(), + new GUI(), null, new LocalResourcePool("pool1"), new LinkedList<InterpreterContextRunner>(), null); @@ -236,6 +238,7 @@ public class RemoteSchedulerTest implements RemoteInterpreterProcessListener { new AuthenticationInfo(), new HashMap<String, Object>(), new GUI(), + new GUI(), null, new LocalResourcePool("pool1"), new LinkedList<InterpreterContextRunner>(), null);
