Details
-
Bug
-
Status: Open
-
Major
-
Resolution: Unresolved
-
0.10.1
-
None
-
None
Description
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:
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
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?