Uploaded image for project: 'Zeppelin'
  1. Zeppelin
  2. ZEPPELIN-6024

The Flink interpreter start fails with " status: ERROR, exception: null, result: %text java.lang.IndexOutOfBoundsException: Index: 0, Size: 0"

    XMLWordPrintableJSON

Details

    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?

       

      Attachments

        Activity

          People

            Unassigned Unassigned
            luhw Hongwei Lu
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated: