Hongwei Lu created ZEPPELIN-6024:
------------------------------------
Summary: The Flink interpreter start fails with " status: ERROR,
exception: null, result: %text java.lang.IndexOutOfBoundsException: Index: 0,
Size: 0"
Key: ZEPPELIN-6024
URL: https://issues.apache.org/jira/browse/ZEPPELIN-6024
Project: Zeppelin
Issue Type: Bug
Components: flink, interpreter-launcher, Interpreters
Affects Versions: 0.10.1
Reporter: Hongwei Lu
Regardless of which _flink.execution.mode_ I configure whether it is
{_}local{_}, {_}yarn{_}, or {_}others{_}, starting any Flink command in
Zeppelin always throws the following exception:
{code:java}
INFO [2024-06-03 17:07:09,822] ({qtp1083962448-15957}
VFSNotebookRepo.java[save]:144) - Saving note 2F2YS7PCE to Flink Tutorial/1.
Flink Basics_2F2YS7PCE.zpln
INFO [2024-06-03 17:07:09,827] ({SchedulerFactory18}
AbstractScheduler.java[runJob]:127) - Job paragraph_1580998084555_-697674675
started by scheduler RemoteInterpreter-flink-shared_process-shared_session
INFO [2024-06-03 17:07:09,828] ({SchedulerFactory18}
Paragraph.java[jobRun]:414) - Run paragraph [paragraph_id:
paragraph_1580998084555_-697674675, interpreter:
org.apache.zeppelin.flink.FlinkInterpreter, note_id: 2F2YS7PCE, user: luhongwei]
INFO [2024-06-03 17:07:09,829] ({SchedulerFactory18}
ManagedInterpreterGroup.java[getOrCreateInterpreterProcess]:65) - Create
InterpreterProcess for InterpreterGroup: flink-shared_process
INFO [2024-06-03 17:07:09,829] ({SchedulerFactory18}
StandardInterpreterLauncher.java[launchDirectly]:50) - Launching new
interpreter process of flink
WARN [2024-06-03 17:07:09,831] ({SchedulerFactory18}
NotebookServer.java[onStatusChange]:1984) - Job
paragraph_1580998084555_-697674675 is finished, status: ERROR, exception: null,
result: %text java.lang.IndexOutOfBoundsException: Index: 0, Size: 0
at java.util.ArrayList.rangeCheck(ArrayList.java:659)
at java.util.ArrayList.get(ArrayList.java:435)
at
org.apache.zeppelin.interpreter.launcher.FlinkInterpreterLauncher.chooseFlinkAppJar(FlinkInterpreterLauncher.java:148)
at
org.apache.zeppelin.interpreter.launcher.FlinkInterpreterLauncher.buildEnvFromProperties(FlinkInterpreterLauncher.java:84)
at
org.apache.zeppelin.interpreter.launcher.StandardInterpreterLauncher.launchDirectly(StandardInterpreterLauncher.java:77)
at
org.apache.zeppelin.interpreter.launcher.InterpreterLauncher.launch(InterpreterLauncher.java:110)
at
org.apache.zeppelin.interpreter.InterpreterSetting.createInterpreterProcess(InterpreterSetting.java:856)
at
org.apache.zeppelin.interpreter.ManagedInterpreterGroup.getOrCreateInterpreterProcess(ManagedInterpreterGroup.java:66)
at
org.apache.zeppelin.interpreter.remote.RemoteInterpreter.getOrCreateInterpreterProcess(RemoteInterpreter.java:104)
at
org.apache.zeppelin.interpreter.remote.RemoteInterpreter.internal_create(RemoteInterpreter.java:154)
at
org.apache.zeppelin.interpreter.remote.RemoteInterpreter.open(RemoteInterpreter.java:126)
at
org.apache.zeppelin.interpreter.remote.RemoteInterpreter.getFormType(RemoteInterpreter.java:271)
at org.apache.zeppelin.notebook.Paragraph.jobRun(Paragraph.java:438)
at org.apache.zeppelin.notebook.Paragraph.jobRun(Paragraph.java:69)
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.RemoteScheduler$JobRunner.run(RemoteScheduler.java:182)
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
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) INFO [2024-06-03 17:07:09,832]
({SchedulerFactory18} VFSNotebookRepo.java[save]:144) - Saving note 2F2YS7PCE
to Flink Tutorial/1. Flink Basics_2F2YS7PCE.zpln
INFO [2024-06-03 17:07:09,835] ({SchedulerFactory18}
AbstractScheduler.java[runJob]:154) - Job paragraph_1580998084555_-697674675
finished by scheduler RemoteInterpreter-flink-shared_process-shared_session
with status ERROR
INFO [2024-06-03 17:07:51,251] ({qtp1083962448-15984}
NotebookServer.java[onClose]:472) - Closed connection to 192.168.208.171:51929
(1001) null
{code}
Is there any missing JAR file? I'm fairly certain that my configuration of the
interpreter is entirely correct.
I'm stuck. Could it be a bug?
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
