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

ZEPPELIN-2943 Streaming output will be closed in 30 seconds for IPythonInterpreter

Browse source
This commit is contained in:
Jeff Zhang 2017-09-19 19:07:52 +08:00
parent 5d7151097e
commit 0923b3cf79
1 changed files with 3 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
python/src/main/resources/grpc/python/ipython_server.py
View file

@ -35,7 +35,7 @@ else:
import queue as queue
TIMEOUT = 30
TIMEOUT = 60*60*24*365*100 # 100 years
class IPython(ipython_pb2_grpc.IPythonServicer):
@ -50,7 +50,8 @@ class IPython(ipython_pb2_grpc.IPythonServicer):
self._status = ipython_pb2.RUNNING
def execute(self, request, context):
print("execute code: " + request.code)
print("execute code:\n")
print(request.code)
sys.stdout.flush()
stdout_queue = queue.Queue(maxsize = 10)
stderr_queue = queue.Queue(maxsize = 10)