1 min readApr 1, 2020
It is weird, do you specify FLINK_HOME else where ? Here’s source code where your issue happens.
File flinkHomeFile = new File(flinkHome);
if (!flinkHomeFile.exists()) {
throw new IOException(String.format("FLINK_HOME {} doesn't exist", flinkHome));
}
There’s one issue in the code, should use %s instead of {}, will fix it soon.