Hi to all,
in my job I'm doing the following to recursively read the files inside a
dir:
TextInputFormat inputFormat = new TextInputFormat(new Path(inputDir));
org.apache.flink.configuration.Configuration ifConf =
new org.apache.flink.configuration.Configuration();
ifConf.setBoolean(FileInputFormat.ENUMERATE_NESTED_FILES_FLAG, true);
inputFormat.configure(ifConf);
ExecutionEnvironment env =
ExecutionEnvironment.getExecutionEnvironment();
env.readFile(inputFormat, inputDir).print();
While inputFormat.configure() sets correctly the enumeratenestedFields
field within TextInputFormat, the execution of the job seems to forget this
parameter and reset it to false.
Am I doing something wrong or there's a bug here (I'm using Flink 1.0.2)?
Best,
Flavio