PLOYING
>> > 11/08/2016 21:22:45 CHAIN Map (Map at mapEdges(Graph.java:596)) ->
>> > FlatMap (FlatMap at getUndirected(Graph.java:926))(1/1) switched to
>> RUNNING
>> > 11/08/2016 21:22:45 CHAIN FlatMap (FlatMap at
>> > fromDataSet(Graph.java:216)) ->
ConnectedComponents$CCMessenger@30f5a68a))(1/1)
>
> switched to SCHEDULED
> 11/08/2016 21:22:48 IterationHead(Scatter-gather iteration
> (org.apache.flink.graph.library.ConnectedComponents$CCUpdater@650eab8 |
> org.apache.flink.graph.library.ConnectedComponents$CCMessenger@30
Head(Scatter-gather iteration
> (org.apache.flink.graph.library.ConnectedComponents$CCUpdater@650eab8 |
> org.apache.flink.graph.library.ConnectedComponents$CCMessenger@30f5a68a))(1/1)
> switched to SCHEDULED
> 11/08/2016 21:22:48 IterationHead(Scatter-gather iteration
> (org.apache.
6 21:22:48 IterationHead(Scatter-gather iteration
(org.apache.flink.graph.library.ConnectedComponents$CCUpdater@650eab8 |
org.apache.flink.graph.library.ConnectedComponents$CCMessenger@30f5a68a))(1/1)
switched to FAILED
java.lang.IllegalArgumentException: Too few memory segments provided. Hash
Table needs at least 33 memory