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
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
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