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