PrabhuJoseph commented on PR #4506:
URL: https://github.com/apache/zeppelin/pull/4506#issuecomment-1356781725
@zjffdu @zenozeng We are facing below issue when running a pyflink from
Zeppelin with this patch on Flink-1.16. It is working fine on Flink-1.15. Any
idea on what could be the issue.
```
%flink.pyflink
table = st_env.sql_query("select * from bank limit 10")
z.show(table)
org.apache.zeppelin.interpreter.InterpreterException:
org.apache.zeppelin.interpreter.InterpreterException: Fail to bootstrap pyflink
at
org.apache.zeppelin.interpreter.LazyOpenInterpreter.open(LazyOpenInterpreter.java:76)
at
org.apache.zeppelin.interpreter.remote.RemoteInterpreterServer$InterpretJob.jobRun(RemoteInterpreterServer.java:844)
at
org.apache.zeppelin.interpreter.remote.RemoteInterpreterServer$InterpretJob.jobRun(RemoteInterpreterServer.java:752)
at org.apache.zeppelin.scheduler.Job.run(Job.java:172)
at
org.apache.zeppelin.scheduler.AbstractScheduler.runJob(AbstractScheduler.java:132)
at
org.apache.zeppelin.scheduler.FIFOScheduler.lambda$runJobInScheduler$0(FIFOScheduler.java:42)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:750)
Caused by: org.apache.zeppelin.interpreter.InterpreterException: Fail to
bootstrap pyflink
at
org.apache.zeppelin.flink.PyFlinkInterpreter.open(PyFlinkInterpreter.java:97)
at
org.apache.zeppelin.interpreter.LazyOpenInterpreter.open(LazyOpenInterpreter.java:70)
... 8 more
Caused by: java.io.IOException: Fail to run bootstrap script:
python/zeppelin_pyflink.py
Fail to execute line 44: st_env =
StreamTableEnvironment(intp.getJavaStreamTableEnvironment())
Traceback (most recent call last):
File "/tmp/zeppelin_python.py", line 180, in <module>
exec(code, _zcUserQueryNameSpace)
File "<stdin>", line 44, in <module>
File
"/usr/lib/flink/opt/python/pyflink.zip/pyflink/table/table_environment.py",
line 1653, in __init__
super(StreamTableEnvironment, self).__init__(j_tenv)
File
"/usr/lib/flink/opt/python/pyflink.zip/pyflink/table/table_environment.py",
line 98, in __init__
self._set_python_executable_for_local_executor()
File
"/usr/lib/flink/opt/python/pyflink.zip/pyflink/table/table_environment.py",
line 1537, in _set_python_executable_for_local_executor
if not j_config.containsKey(jvm.PythonOptions.PYTHON_EXECUTABLE.key()) \
TypeError: 'JavaPackage' object is not callable
at
org.apache.zeppelin.python.PythonInterpreter.bootstrapInterpreter(PythonInterpreter.java:580)
at
org.apache.zeppelin.flink.PyFlinkInterpreter.open(PyFlinkInterpreter.java:95)
... 9 more
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
