[ZEPPELIN-5803] IndexOutOfBoundsException thrown by chooseFlinkAppJar when no name start with "flink-dist_"

• Type: Bug
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 0.10.1
• Component/s: flink

Environment

CentOS

• Assignee: Unassigned
• Reporter: Xiaokang Gong
• Created: 26/Aug/22 08:47
• Updated: 16/Sep/22 08:57

Description

Zeppelin version 0.10.1

Flink version: 1.15.2 & 1.14.5 & 1.13.6

File flinkLibFolder = new File(flinkHome, "lib");
List<File> flinkDistFiles =
Arrays.stream(flinkLibFolder.listFiles(file -> file.getName().contains("flink-dist_")))
.collect(Collectors.toList());
if (flinkDistFiles.size() > 1)
{ throw new IOException("More than 1 flink-dist files: " + flinkDistFiles.stream() .map(file -> file.getAbsolutePath()) .collect(Collectors.joining(","))); }
String scalaVersion = "2.11";
if (flinkDistFiles.get(0).getName().contains("2.12"))
{ scalaVersion = "2.12"; } 

when no jar file contains "flink-dist_" found, flinkDistFiles.get(0) will throw an IndexOutOfBoundsException.

while jar file starts with "flink-dist_" is not shown in flink 1.15.2 1.14.5 1.13.6, which is assumed to be a series problem.