Hi Flavio,
As Aljoscha pointed out the problem must be solved now.
The changes are already in the master.
If there is any issue let us know.
Kostas
> On Jul 20, 2016, at 6:29 PM, Aljoscha Krettek wrote:
>
> Hi,
> the configuration has to be passed using
> env.readFile(...).withParameters(ifCo
Hi,
the configuration has to be passed using
env.readFile(...).withParameters(ifConf). The InputFormat will then be
properly configured at runtime.
However, Kostas just enhanced the FileInputFormats to allow setting the
parameters directly on the input format. In 1.1-SNAPSHOT and the upcoming
1.1
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.setBool
