RE: Crash on DataSet.collect()

2015-05-04 Thread Flavio Baronti
Subject: Re: Crash on DataSet.collect() Hi Flavio! This issue is known and has been fixed already. It occurs when you use custom types in collect, because it uses the wrong classloader/serializer to transfer them. The current master should not have this issue any more. Greetings

Re: Crash on DataSet.collect()

2015-05-04 Thread Stephan Ewen
Hi Flavio! This issue is known and has been fixed already. It occurs when you use custom types in collect, because it uses the wrong classloader/serializer to transfer them. The current master should not have this issue any more. Greetings, Stephan On Mon, May 4, 2015 at 2:09 PM, Flavio Baront

Crash on DataSet.collect()

2015-05-04 Thread Flavio Baronti
Hello, I'm testing the new DataSet.collect() method on version 0.9-milestone-1, but I obtain the following error on cluster execution (no problem with local execution), which also causes the job manager to crash: 14:05:41,145 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deployin