muller created ZEPPELIN-5554:
--------------------------------
Summary: run zeppelin 0.10 flink interpreter can not use
Key: ZEPPELIN-5554
URL: https://issues.apache.org/jira/browse/ZEPPELIN-5554
Project: Zeppelin
Issue Type: Bug
Components: interpreter-launcher
Affects Versions: 0.10.0
Environment: jdk 11
scala 2.12.12 Scala 2.12.12 (Eclipse OpenJ9 VM, Java 11.0.10)
flink flink-1.13.2-bin-scala_2.12.tgz
zeppelin 0.10
Reporter: muller
Fix For: 0.10.0
when I use flink interpreter meet some error ,I have see the flink interpreter
demon process is running ,but when I run the scala -flink mode tell me can
not open flink interpreter ,feel confused ,
I just import some flink dependency
```
import org.apache.flink.api.common.typeinfo.Types
import org.apache.flink.api.java.typeutils._
import org.apache.flink.api.scala.typeutils._
import org.apache.flink.api.scala._
import org.apache.flink.streaming.api.scala.\{DataStream,
StreamExecutionEnvironment}
import org.apache.flink.table.api.\{DataTypes, EnvironmentSettings}
import org.apache.flink.table.api.bridge.scala.StreamTableEnvironment
import org.apache.flink.table.descriptors.\{Csv, FileSystem, Schema}
import org.apache.flink.table.factories.TableSourceFactory
```
```
org.apache.zeppelin.interpreter.InterpreterException:
org.apache.zeppelin.interpreter.InterpreterException: Fail to open
FlinkInterpreter at
org.apache.zeppelin.interpreter.LazyOpenInterpreter.open(LazyOpenInterpreter.java:76)
at
org.apache.zeppelin.interpreter.remote.RemoteInterpreterServer$InterpretJob.jobRun(RemoteInterpreterServer.java:833)
at
org.apache.zeppelin.interpreter.remote.RemoteInterpreterServer$InterpretJob.jobRun(RemoteInterpreterServer.java:741)
at org.apache.zeppelin.scheduler.Job.run(Job.java:172) at
org.apache.zeppelin.scheduler.AbstractScheduler.runJob(AbstractScheduler.java:132)
at
org.apache.zeppelin.scheduler.FIFOScheduler.lambda$runJobInScheduler$0(FIFOScheduler.java:42)
at
org.apache.zeppelin.scheduler.FIFOScheduler$$Lambda$337/0x0000000000000000.run(Unknown
Source) at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:836) Caused by:
org.apache.zeppelin.interpreter.InterpreterException: Fail to open
FlinkInterpreter at
org.apache.zeppelin.flink.FlinkInterpreter.open(FlinkInterpreter.java:80) at
org.apache.zeppelin.interpreter.LazyOpenInterpreter.open(LazyOpenInterpreter.java:70)
... 9 more Caused by: java.lang.IllegalArgumentException: argument type
mismatch at
java.base/jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance0(Native
Method) at
java.base/jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
at
java.base/jdk.internal.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
at java.base/java.lang.reflect.Constructor.newInstance(Constructor.java:490)
at
org.apache.zeppelin.flink.FlinkInterpreter.loadFlinkScalaInterpreter(FlinkInterpreter.java:98)
at org.apache.zeppelin.flink.FlinkInterpreter.open(FlinkInterpreter.java:74)
... 10 more
```
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
