Not zeppelin lib folder, put it in flink lib folder Craftman Tel <craftman...@gmail.com> 于2020年4月8日周三 下午10:39写道：
> Thanks for the reply. I just tested adding the jar to Zeppelin lib folder, > restarted everything and the issue is still there. Any other ideas? > > Thanks > > Le mer. 8 avr. 2020 à 15:57, Jeff Zhang <zjf...@gmail.com> a écrit : > >> You need to copy flink-python_2.11-1.10.0.jar from flink opt folder to >> flink lib folder. Thanks for the feedback, I need to update the document. >> >> Craftman Tel <craftman...@gmail.com> 于2020年4月8日周三 下午9:38写道： >> >>> Hello, >>> >>> I am testing the integration of Zeppelin with our Flink on Yarn. I so >>> far successfully run batch flink program. However, when I try to use >>> FlinkSQL (%flink.bsql or %flink.ssql) I get the following error >>> >>> Can someone help me resolve this issue? where can I find this class? I >>> searched in the Flink shaded jar with no luck >>> >>> org.apache.zeppelin.interpreter.InterpreterException: >>> java.lang.NoClassDefFoundError: org/apache/flink/python/PythonOptions at >>> org.apache.zeppelin.interpreter.LazyOpenInterpreter.open(LazyOpenInterpreter.java:76) >>> at >>> org.apache.zeppelin.interpreter.remote.RemoteInterpreterServer$InterpretJob.jobRun(RemoteInterpreterServer.java:668) >>> at >>> org.apache.zeppelin.interpreter.remote.RemoteInterpreterServer$InterpretJob.jobRun(RemoteInterpreterServer.java:577) >>> at org.apache.zeppelin.scheduler.Job.run(Job.java:172) at >>> org.apache.zeppelin.scheduler.AbstractScheduler.runJob(AbstractScheduler.java:130) >>> at >>> org.apache.zeppelin.scheduler.ParallelScheduler.lambda$runJobInScheduler$0(ParallelScheduler.java:39) >>> 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:748) Caused by: >>> java.lang.NoClassDefFoundError: org/apache/flink/python/PythonOptions at >>> org.apache.zeppelin.flink.FlinkSqlInterrpeter.extractTableConfigOptions(FlinkSqlInterrpeter.java:135) >>> at >>> org.apache.zeppelin.flink.FlinkSqlInterrpeter.open(FlinkSqlInterrpeter.java:128) >>> at >>> org.apache.zeppelin.flink.FlinkStreamSqlInterpreter.open(FlinkStreamSqlInterpreter.java:48) >>> at >>> org.apache.zeppelin.interpreter.LazyOpenInterpreter.open(LazyOpenInterpreter.java:70) >>> ... 8 more >>> >>> Thanks >>> >> >> >> -- >> Best Regards >> >> Jeff Zhang >> > -- Best Regards Jeff Zhang
