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 <trohrm...@apache.org> 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 >