mirror of
https://github.com/apache/zeppelin
synced 2026-05-24 09:38:26 +00:00
Merge remote-tracking branch 'origin/master' into ZEPPELIN-212
This commit is contained in:
commit
282504ea3e
4 changed files with 3 additions and 11 deletions
|
|
@ -73,7 +73,7 @@ public class PythonDockerInterpreterTest {
|
|||
return new InterpreterContext(
|
||||
"noteId",
|
||||
"paragraphId",
|
||||
null,
|
||||
"replName",
|
||||
"paragraphTitle",
|
||||
"paragraphText",
|
||||
new AuthenticationInfo(),
|
||||
|
|
|
|||
|
|
@ -17,18 +17,14 @@
|
|||
package org.apache.zeppelin.interpreter.remote;
|
||||
|
||||
import com.google.gson.Gson;
|
||||
import org.apache.commons.exec.*;
|
||||
import org.apache.commons.pool2.impl.GenericObjectPool;
|
||||
import org.apache.thrift.TException;
|
||||
import org.apache.zeppelin.helium.ApplicationEventListener;
|
||||
import org.apache.zeppelin.interpreter.Constants;
|
||||
import org.apache.zeppelin.interpreter.InterpreterException;
|
||||
import org.apache.zeppelin.interpreter.InterpreterGroup;
|
||||
import org.apache.zeppelin.interpreter.thrift.RemoteInterpreterService.Client;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
import java.util.concurrent.atomic.AtomicInteger;
|
||||
import java.util.Properties;
|
||||
|
||||
/**
|
||||
* Abstract class for interpreter process
|
||||
|
|
@ -36,14 +32,11 @@ import java.util.Properties;
|
|||
public abstract class RemoteInterpreterProcess {
|
||||
private static final Logger logger = LoggerFactory.getLogger(RemoteInterpreterProcess.class);
|
||||
private final AtomicInteger referenceCount;
|
||||
private ExecuteWatchdog watchdog;
|
||||
|
||||
private GenericObjectPool<Client> clientPool;
|
||||
private final RemoteInterpreterEventPoller remoteInterpreterEventPoller;
|
||||
private final InterpreterContextRunnerPool interpreterContextRunnerPool;
|
||||
private int connectTimeout;
|
||||
String host = "localhost";
|
||||
boolean isInterpreterAlreadyExecuting = false;
|
||||
|
||||
public RemoteInterpreterProcess(
|
||||
int connectTimeout,
|
||||
|
|
|
|||
|
|
@ -69,7 +69,6 @@ public class RemoteInterpreterServer
|
|||
Gson gson = new Gson();
|
||||
|
||||
RemoteInterpreterService.Processor<RemoteInterpreterServer> processor;
|
||||
RemoteInterpreterServer handler;
|
||||
private int port;
|
||||
private TThreadPoolServer server;
|
||||
|
||||
|
|
|
|||
|
|
@ -7,7 +7,8 @@
|
|||
"postinstall": "node_modules/.bin/bower install --silent",
|
||||
"build": "./node_modules/.bin/grunt build",
|
||||
"start": "./node_modules/.bin/grunt serve",
|
||||
"test": "./node_modules/.bin/grunt test"
|
||||
"test": "./node_modules/.bin/grunt test",
|
||||
"pretest": "./node_modules/.bin/npm install karma-phantomjs-launcher"
|
||||
},
|
||||
"dependencies": {
|
||||
"grunt-angular-templates": "^0.5.7",
|
||||
|
|
@ -47,7 +48,6 @@
|
|||
"karma": "~1.3.0",
|
||||
"karma-coverage": "^1.1.1",
|
||||
"karma-jasmine": "~1.0.2",
|
||||
"karma-phantomjs-launcher": "~1.0.2",
|
||||
"load-grunt-tasks": "^0.4.0",
|
||||
"time-grunt": "^0.3.1"
|
||||
},
|
||||
|
|
|
|||
Loading…
Reference in a new issue