Xiaokang Gong created ZEPPELIN-5803:
---------------------------------------
Summary: IndexOutOfBoundsException thrown by chooseFlinkAppJar
when no name start with "flink-dist_"
Key: ZEPPELIN-5803
URL: https://issues.apache.org/jira/browse/ZEPPELIN-5803
Project: Zeppelin
Issue Type: Bug
Components: flink
Affects Versions: 0.10.1
Environment: CentOS
Reporter: Xiaokang Gong
Zeppelin version 0.10.1
Flink version: 1.15.2 & 1.14.5 & 1.13.6
```java
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.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
