Do you have any suggestion about how to reproduce the error on a subset of
the data?
I'm trying changing the following but I can't find a configuration causing
the error :(
rivate static ExecutionEnvironment getLocalExecutionEnv() {
org.apache.flink.configuration.Configuration c = new
org.apache.flink.configuration.Configuration();
c.setString(ConfigConstants.TASK_MANAGER_TMP_DIR_KEY, "/tmp");
c.setString(ConfigConstants.BLOB_STORAGE_DIRECTORY_KEY,"/tmp");
c.setFloat(ConfigConstants.TASK_MANAGER_MEMORY_FRACTION_KEY, 0.9f);
c.setLong(ConfigConstants.LOCAL_NUMBER_TASK_MANAGER, 4);
c.setLong(ConfigConstants.TASK_MANAGER_NUM_TASK_SLOTS, 4);
c.setString(ConfigConstants.AKKA_ASK_TIMEOUT, "10000 s");
c.setLong(ConfigConstants.TASK_MANAGER_NETWORK_NUM_BUFFERS_KEY,
2048 * 12);
ExecutionEnvironment env =
ExecutionEnvironment.createLocalEnvironment(c);
env.setParallelism(16);
env.registerTypeWithKryoSerializer(DateTime.class,
JodaDateTimeSerializer.class );
return env;
}
Best,
Flavio
On Tue, May 24, 2016 at 11:13 AM, Till Rohrmann <[email protected]>
wrote:
> The error look really strange. Flavio, could you compile a test program
> with example data and configuration to reproduce the problem. Given that,
> we could try to debug the problem.
>
> Cheers,
> Till
>
