IssueTracker

Issue:

unable to access the flink from zeppelin notebook part of dataproc cluster.

Error being received:

"\norg.apache.zeppelin.interpreter.InterpreterException: org.apache.zeppelin.interpreter.InterpreterException:\
\ org.apache.zeppelin.interpreter.InterpreterException: Fail to open FlinkInterpreter\n\
\tat org.apache.zeppelin.interpreter.LazyOpenInterpreter.open(LazyOpenInterpreter.java:76)\n\
\tat org.apache.zeppelin.interpreter.remote.RemoteInterpreterServer$InterpretJob.jobRun(RemoteInterpreterServer.java:844)\n\
\tat org.apache.zeppelin.interpreter.remote.RemoteInterpreterServer$InterpretJob.jobRun(RemoteInterpreterServer.java:752)\n\
\tat org.apache.zeppelin.scheduler.Job.run(Job.java:172)\n\tat org.apache.zeppelin.scheduler.AbstractScheduler.runJob(AbstractScheduler.java:132)\n\
\tat org.apache.zeppelin.scheduler.ParallelScheduler.lambda$runJobInScheduler$0(ParallelScheduler.java:46)\n\
\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)\n\
\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)\n\
\tat java.base/java.lang.Thread.run(Thread.java:829)\nCaused by: org.apache.zeppelin.interpreter.InterpreterException:\
\ org.apache.zeppelin.interpreter.InterpreterException: Fail to open FlinkInterpreter\n\
\tat org.apache.zeppelin.interpreter.LazyOpenInterpreter.open(LazyOpenInterpreter.java:76)\n\
\tat org.apache.zeppelin.interpreter.Interpreter.getInterpreterInTheSameSessionByClassName(Interpreter.java:322)\n\
\tat org.apache.zeppelin.interpreter.Interpreter.getInterpreterInTheSameSessionByClassName(Interpreter.java:333)\n\
\tat org.apache.zeppelin.flink.FlinkSqlInterpreter.open(FlinkSqlInterpreter.java:43)\n\
\tat org.apache.zeppelin.flink.FlinkBatchSqlInterpreter.open(FlinkBatchSqlInterpreter.java:36)\n\
\tat org.apache.zeppelin.interpreter.LazyOpenInterpreter.open(LazyOpenInterpreter.java:70)\n\
\t... 8 more\nCaused by: org.apache.zeppelin.interpreter.InterpreterException: Fail\
\ to open FlinkInterpreter\n\tat org.apache.zeppelin.flink.FlinkInterpreter.open(FlinkInterpreter.java:76)\n\
\tat org.apache.zeppelin.interpreter.LazyOpenInterpreter.open(LazyOpenInterpreter.java:70)\n\
\t... 13 more\nCaused by: java.lang.IllegalArgumentException: argument type mismatch\n\
\tat java.base/jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance0(Native\
\ Method)\n\tat java.base/jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)\n\
\tat java.base/jdk.internal.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)\n\
\tat java.base/java.lang.reflect.Constructor.newInstance(Constructor.java:490)\n\
\tat org.apache.zeppelin.flink.FlinkInterpreter.loadFlinkScalaInterpreter(FlinkInterpreter.java:94)\n\
\tat org.apache.zeppelin.flink.FlinkInterpreter.open(FlinkInterpreter.java:70)\n\
\t... 14 more"

Multiple config changes in Flink interpreter also not helping.

Cause of issue is due to: https://issues.apache.org/jira/browse/ZEPPELIN-5554

This feature request is to track the fix as mentioned in above JIRA and how it can be pushed to Dataproc.