Jeff Zhang
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.

--

--

Jeff Zhang
Jeff Zhang

Written by Jeff Zhang

Apache Member, Open source veteran, Big Data, Data Science,

No responses yet