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

Reply via email to