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 >
