mirror of
https://github.com/apache/zeppelin
synced 2026-05-24 09:38:26 +00:00
address comments
This commit is contained in:
parent
7e885bd388
commit
a87c4250f9
2 changed files with 4 additions and 2 deletions
|
|
@ -39,7 +39,7 @@ public class ZeppelinDevServer extends
|
|||
private DevInterpreter interpreter = null;
|
||||
private InterpreterOutput out;
|
||||
public ZeppelinDevServer(int port) throws TException, IOException {
|
||||
super(null, port, "");
|
||||
super(null, port, ":");
|
||||
}
|
||||
|
||||
@Override
|
||||
|
|
|
|||
|
|
@ -29,6 +29,8 @@ import java.net.Socket;
|
|||
import java.net.SocketException;
|
||||
import java.net.UnknownHostException;
|
||||
import java.util.Collections;
|
||||
|
||||
import org.apache.commons.lang.StringUtils;
|
||||
import org.apache.thrift.TException;
|
||||
import org.apache.thrift.protocol.TBinaryProtocol;
|
||||
import org.apache.thrift.protocol.TProtocol;
|
||||
|
|
@ -70,7 +72,7 @@ public class RemoteInterpreterUtils {
|
|||
|
||||
TServerSocket tSocket = null;
|
||||
// ':' is the default value which means no constraints on the portRange
|
||||
if (portRange == null || portRange.equals(":")) {
|
||||
if (StringUtils.isBlank(portRange) || portRange.equals(":")) {
|
||||
try {
|
||||
tSocket = new TServerSocket(0);
|
||||
return tSocket;
|
||||
|
|
|
|||
Loading…
Reference in a new issue