Oh my bad. Thank you very much, it worked. Le mer. 8 avr. 2020 à 16:43, Jeff Zhang <zjf...@gmail.com> a écrit :
> 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 >
