Elgato_dark/zeppelin
1
0
Fork 0
mirror of https://github.com/apache/zeppelin synced 2026-05-24 09:38:26 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

[HOTFIX] rename zeppelin.ipython.grpc.framesize to zeppelin.ipython.grpc.message_size

Browse source
This commit is contained in:
Jeff Zhang 2018-02-24 14:25:38 +08:00
parent ea2c944742
commit d899a299f2
3 changed files with 7 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
python/src/main/java/org/apache/zeppelin/python/IPythonInterpreter.java
View file

@ -143,10 +143,10 @@ public class IPythonInterpreter extends Interpreter implements ExecuteResultHand
int jvmGatewayPort = RemoteInterpreterUtils.findRandomAvailablePortOnAllLocalInterfaces();
LOGGER.info("Launching IPython Kernel at port: " + ipythonPort);
LOGGER.info("Launching JVM Gateway at port: " + jvmGatewayPort);
int framesize = Integer.parseInt(getProperty("zeppelin.ipython.grpc.framesize",
int message_size = Integer.parseInt(getProperty("zeppelin.ipython.grpc.message_size",
32 * 1024 * 1024 + ""));
ipythonClient = new IPythonClient(ManagedChannelBuilder.forAddress("127.0.0.1", ipythonPort)
.usePlaintext(true).maxInboundMessageSize(framesize));
.usePlaintext(true).maxInboundMessageSize(message_size));
launchIPythonKernel(ipythonPort);
setupJVMGateway(jvmGatewayPort);
} catch (Exception e) {

6
python/src/main/resources/interpreter-setting.json
View file

@ -41,10 +41,10 @@
"description": "time out for ipython launch",
"type": "number"
},
"zeppelin.ipython.grpc.framesize": {
"propertyName": "zeppelin.ipython.grpc.framesize",
"zeppelin.ipython.grpc.message_size": {
"propertyName": "zeppelin.ipython.grpc.message_size",
"defaultValue": "33554432",
"description": "grpc framesize, default is 32M",
"description": "grpc message size, default is 32M",
"type": "number"
}
},

4
python/src/test/java/org/apache/zeppelin/python/IPythonInterpreterTest.java
View file

@ -78,7 +78,7 @@ public class IPythonInterpreterTest {
@Test
public void testGrpcFrameSize() throws InterpreterException, IOException {
Properties properties = new Properties();
properties.setProperty("zeppelin.ipython.grpc.framesize", "4");
properties.setProperty("zeppelin.ipython.grpc.message_size", "4");
startInterpreter(properties);
// to make this test can run under both python2 and python3
@ -99,7 +99,7 @@ public class IPythonInterpreterTest {
close();
// increase framesize to make it work
properties.setProperty("zeppelin.ipython.grpc.framesize", "40");
properties.setProperty("zeppelin.ipython.grpc.message_size", "40");
startInterpreter(properties);
// to make this test can run under both python2 and python3
result = interpreter.interpret("from __future__ import print_function", getInterpreterContext());