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
