flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Vasiliki Kalavri <vasilikikala...@gmail.com>
Subject Re: [gelly] Tests fail, but build succeeds
Date Tue, 10 Mar 2015 14:05:09 GMT
Hi Stephan,

what you see isn't a test failure, it comes from
http://github.com/apache/flink/pull/440 and it's testing that an exception
is thrown.

The output isn't coming from logging, it's sysout coming from the
JobClient, so I couldn't turn it off.

I was actually meaning to start a discussion about changing this, but I
forgot, sorry..
Any suggestions on this then?

Thanks!
-Vasia.

On 10 March 2015 at 14:53, Stephan Ewen <sewen@apache.org> wrote:

> It seems JobExecution failures are not recognized in some of the Gelly
> tests.
>
> Also, the tests are logging quite a bit, would be nice to make them a bit
> more quiet.
> How is the logging is created, btw. The log4j-tests.properties have the log
> level set to OFF afaik.
>
> Here is a log from my latest build:
>
> Running org.apache.flink.graph.test.operations.FromCollectionITCase
>
> Running org.apache.flink.graph.test.operations.JoinWithVerticesITCase
> Tests run: 6, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 3.844
> sec - in org.apache.flink.graph.test.operations.FromCollectionITCase
> Running org.apache.flink.graph.test.operations.GraphCreationITCase
> Tests run: 10, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 6.254
> sec - in org.apache.flink.graph.test.operations.JoinWithVerticesITCase
> Running
> org.apache.flink.graph.test.operations.ReduceOnNeighborMethodsITCase
> Tests run: 10, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 5.622
> sec - in org.apache.flink.graph.test.operations.GraphCreationITCase
> Running org.apache.flink.graph.test.operations.GraphMutationsITCase
> Tests run: 12, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 5.631
> sec - in
> org.apache.flink.graph.test.operations.ReduceOnNeighborMethodsITCase
> Running
> org.apache.flink.graph.test.operations.GraphCreationWithMapperITCase
> Tests run: 18, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 3.827
> sec - in org.apache.flink.graph.test.operations.GraphMutationsITCase
> Running org.apache.flink.graph.test.operations.GraphOperationsITCase
> Tests run: 8, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 5.177
> sec - in
> org.apache.flink.graph.test.operations.GraphCreationWithMapperITCase
> Running org.apache.flink.graph.test.operations.MapVerticesITCase
> Tests run: 20, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 4.299
> sec - in org.apache.flink.graph.test.operations.GraphOperationsITCase
> Running org.apache.flink.graph.test.operations.ReduceOnEdgesMethodsITCase
> Tests run: 10, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 3.916
> sec - in org.apache.flink.graph.test.operations.MapVerticesITCase
> Running org.apache.flink.graph.test.operations.JoinWithEdgesITCase
> Tests run: 12, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 6.375
> sec - in org.apache.flink.graph.test.operations.ReduceOnEdgesMethodsITCase
> Running org.apache.flink.graph.test.operations.MapEdgesITCase
> Tests run: 10, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 3.238
> sec - in org.apache.flink.graph.test.operations.MapEdgesITCase
> Running org.apache.flink.graph.test.operations.DegreesITCase
> Tests run: 30, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 9.136
> sec - in org.apache.flink.graph.test.operations.JoinWithEdgesITCase
> Running org.apache.flink.graph.test.example.SingleSourceShortestPathsITCase
> Tests run: 12, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 6.08
> sec - in org.apache.flink.graph.test.operations.DegreesITCase
> Running org.apache.flink.graph.test.example.LabelPropagationExampleITCase
> Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 4.102
> sec - in
> org.apache.flink.graph.test.example.SingleSourceShortestPathsITCase
> Running org.apache.flink.graph.test.DegreesWithExceptionITCase
> 03/10/2015 13:44:04     Job execution switched to status RUNNING.
> 03/10/2015 13:44:04     DataSource (at
> getLongLongVertexData(TestGraphUtils.java:37)
> (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to
> SCHEDULED
> 03/10/2015 13:44:04     DataSource (at
> getLongLongVertexData(TestGraphUtils.java:37)
> (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to
> DEPLOYING
> 03/10/2015 13:44:04     DataSource (at
> getLongLongEdgeInvalidSrcData(TestGraphUtils.java:53)
> (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to
> SCHEDULED
> 03/10/2015 13:44:04     DataSource (at
> getLongLongEdgeInvalidSrcData(TestGraphUtils.java:53)
> (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to
> DEPLOYING
> 03/10/2015 13:44:04     DataSource (at
> getLongLongVertexData(TestGraphUtils.java:37)
> (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to
> RUNNING
> 03/10/2015 13:44:04     DataSource (at
> getLongLongEdgeInvalidSrcData(TestGraphUtils.java:53)
> (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to
> RUNNING
> 03/10/2015 13:44:04     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(2/16) switched to SCHEDULED
> 03/10/2015 13:44:04     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(3/16) switched to SCHEDULED
> 03/10/2015 13:44:04     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(2/16) switched to DEPLOYING
> 03/10/2015 13:44:04     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(3/16) switched to DEPLOYING
> 03/10/2015 13:44:04     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(4/16) switched to SCHEDULED
> 03/10/2015 13:44:04     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(4/16) switched to DEPLOYING
> 03/10/2015 13:44:04     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(5/16) switched to SCHEDULED
> 03/10/2015 13:44:04     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(5/16) switched to DEPLOYING
> 03/10/2015 13:44:04     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(6/16) switched to SCHEDULED
> 03/10/2015 13:44:04     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(6/16) switched to DEPLOYING
> 03/10/2015 13:44:04     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(7/16) switched to SCHEDULED
> 03/10/2015 13:44:04     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(7/16) switched to DEPLOYING
> 03/10/2015 13:44:04     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(8/16) switched to SCHEDULED
> 03/10/2015 13:44:04     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(8/16) switched to DEPLOYING
> 03/10/2015 13:44:04     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(9/16) switched to SCHEDULED
> 03/10/2015 13:44:04     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(9/16) switched to DEPLOYING
> 03/10/2015 13:44:04     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(10/16) switched to SCHEDULED
> 03/10/2015 13:44:04     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(10/16) switched to DEPLOYING
> 03/10/2015 13:44:04     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(11/16) switched to SCHEDULED
> 03/10/2015 13:44:04     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(11/16) switched to DEPLOYING
> 03/10/2015 13:44:04     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(12/16) switched to SCHEDULED
> 03/10/2015 13:44:04     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(12/16) switched to DEPLOYING
> 03/10/2015 13:44:04     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(1/16) switched to SCHEDULED
> 03/10/2015 13:44:04     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(1/16) switched to DEPLOYING
> 03/10/2015 13:44:04     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(13/16) switched to SCHEDULED
> 03/10/2015 13:44:04     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(13/16) switched to DEPLOYING
> 03/10/2015 13:44:04     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(14/16) switched to SCHEDULED
> 03/10/2015 13:44:04     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(14/16) switched to DEPLOYING
> 03/10/2015 13:44:04     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(15/16) switched to SCHEDULED
> 03/10/2015 13:44:04     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(15/16) switched to DEPLOYING
> 03/10/2015 13:44:04     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(16/16) switched to SCHEDULED
> 03/10/2015 13:44:04     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(16/16) switched to DEPLOYING
> 03/10/2015 13:44:04     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(2/16) switched to RUNNING
> 03/10/2015 13:44:04     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(6/16) switched to RUNNING
> 03/10/2015 13:44:04     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(4/16) switched to RUNNING
> 03/10/2015 13:44:04     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(3/16) switched to RUNNING
> 03/10/2015 13:44:04     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(5/16) switched to RUNNING
> 03/10/2015 13:44:04     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(7/16) switched to RUNNING
> 03/10/2015 13:44:04     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(16/16) switched to RUNNING
> 03/10/2015 13:44:04     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(15/16) switched to RUNNING
> 03/10/2015 13:44:04     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(14/16) switched to RUNNING
> 03/10/2015 13:44:04     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(13/16) switched to RUNNING
> 03/10/2015 13:44:04     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(1/16) switched to RUNNING
> 03/10/2015 13:44:04     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(12/16) switched to RUNNING
> 03/10/2015 13:44:04     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(11/16) switched to RUNNING
> 03/10/2015 13:44:04     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(10/16) switched to RUNNING
> 03/10/2015 13:44:04     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(9/16) switched to RUNNING
> 03/10/2015 13:44:04     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(8/16) switched to RUNNING
> 03/10/2015 13:44:04     DataSource (at
> getLongLongEdgeInvalidSrcData(TestGraphUtils.java:53)
> (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to
> FINISHED
> 03/10/2015 13:44:04
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(11/16)
> switched to SCHEDULED
> 03/10/2015 13:44:04
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(11/16)
> switched to DEPLOYING
> 03/10/2015 13:44:04
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(16/16)
> switched to SCHEDULED
> 03/10/2015 13:44:04
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(16/16)
> switched to DEPLOYING
> 03/10/2015 13:44:04
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(7/16)
> switched to SCHEDULED
> 03/10/2015 13:44:04
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(7/16)
> switched to DEPLOYING
> 03/10/2015 13:44:04
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(15/16)
> switched to SCHEDULED
> 03/10/2015 13:44:04
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(15/16)
> switched to DEPLOYING
> 03/10/2015 13:44:04
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(14/16)
> switched to SCHEDULED
> 03/10/2015 13:44:04
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(14/16)
> switched to DEPLOYING
> 03/10/2015 13:44:04
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(13/16)
> switched to SCHEDULED
> 03/10/2015 13:44:04
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(13/16)
> switched to DEPLOYING
> 03/10/2015 13:44:04
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(5/16)
> switched to SCHEDULED
> 03/10/2015 13:44:04
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(5/16)
> switched to DEPLOYING
> 03/10/2015 13:44:04
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(12/16)
> switched to SCHEDULED
> 03/10/2015 13:44:04
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(12/16)
> switched to DEPLOYING
> 03/10/2015 13:44:04
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(1/16)
> switched to SCHEDULED
> 03/10/2015 13:44:04
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(1/16)
> switched to DEPLOYING
> 03/10/2015 13:44:04
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(10/16)
> switched to SCHEDULED
> 03/10/2015 13:44:04
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(10/16)
> switched to DEPLOYING
> 03/10/2015 13:44:04
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(6/16)
> switched to SCHEDULED
> 03/10/2015 13:44:04
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(6/16)
> switched to DEPLOYING
> 03/10/2015 13:44:04     DataSource (at
> getLongLongVertexData(TestGraphUtils.java:37)
> (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to
> FINISHED
> 03/10/2015 13:44:04
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(8/16)
> switched to SCHEDULED
> 03/10/2015 13:44:04
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(8/16)
> switched to DEPLOYING
> 03/10/2015 13:44:04
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(4/16)
> switched to SCHEDULED
> 03/10/2015 13:44:04
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(4/16)
> switched to DEPLOYING
> 03/10/2015 13:44:04     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(7/16) switched to FINISHED
> 03/10/2015 13:44:04     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(16/16) switched to FINISHED
> 03/10/2015 13:44:04     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(15/16) switched to FINISHED
> 03/10/2015 13:44:04
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(11/16)
> switched to RUNNING
> 03/10/2015 13:44:04
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(16/16)
> switched to RUNNING
> 03/10/2015 13:44:04
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(7/16)
> switched to RUNNING
> 03/10/2015 13:44:04
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(15/16)
> switched to RUNNING
> 03/10/2015 13:44:04
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(14/16)
> switched to RUNNING
> 03/10/2015 13:44:04
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(13/16)
> switched to RUNNING
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(1/16) switched to FINISHED
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(12/16) switched to FINISHED
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(10/16) switched to FINISHED
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(11/16) switched to FINISHED
> 03/10/2015 13:44:05
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(5/16)
> switched to RUNNING
> 03/10/2015 13:44:05
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(12/16)
> switched to RUNNING
> 03/10/2015 13:44:05
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(1/16)
> switched to RUNNING
> 03/10/2015 13:44:05
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(10/16)
> switched to RUNNING
> 03/10/2015 13:44:05
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(6/16)
> switched to RUNNING
> 03/10/2015 13:44:05
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(8/16)
> switched to RUNNING
> 03/10/2015 13:44:05
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(4/16)
> switched to RUNNING
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(5/16) switched to FINISHED
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(13/16) switched to FINISHED
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(14/16) switched to FINISHED
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(8/16) switched to FINISHED
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(9/16) switched to FAILED
> java.util.NoSuchElementException: The edge src/trg id could not be
> found within the vertexIds
>         at
> org.apache.flink.graph.Graph$CountNeighborsCoGroup.coGroup(Graph.java:643)
>         at
> org.apache.flink.runtime.operators.CoGroupDriver.run(CoGroupDriver.java:152)
>         at
> org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:496)
>         at
> org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:362)
>         at
> org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:205)
>         at java.lang.Thread.run(Thread.java:701)
>
> 03/10/2015 13:44:05     Job execution switched to status FAILING.
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(2/16) switched to CANCELING
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(3/16) switched to CANCELING
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(4/16) switched to CANCELING
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(6/16) switched to CANCELING
> 03/10/2015 13:44:05
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(1/16)
> switched to CANCELING
> 03/10/2015 13:44:05
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(2/16)
> switched to CANCELED
> 03/10/2015 13:44:05
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(3/16)
> switched to CANCELED
> 03/10/2015 13:44:05
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(4/16)
> switched to CANCELING
> 03/10/2015 13:44:05
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(5/16)
> switched to CANCELING
> 03/10/2015 13:44:05
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(6/16)
> switched to CANCELING
> 03/10/2015 13:44:05
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(7/16)
> switched to CANCELING
> 03/10/2015 13:44:05
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(8/16)
> switched to CANCELING
> 03/10/2015 13:44:05
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(11/16)
> switched to FINISHED
> 03/10/2015 13:44:05
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(16/16)
> switched to FINISHED
> 03/10/2015 13:44:05
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(7/16)
> switched to CANCELED
> 03/10/2015 13:44:05
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(15/16)
> switched to FINISHED
> 03/10/2015 13:44:05
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(14/16)
> switched to FINISHED
> 03/10/2015 13:44:05
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(13/16)
> switched to FINISHED
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(4/16) switched to CANCELED
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(6/16) switched to CANCELED
> 03/10/2015 13:44:05
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(5/16)
> switched to CANCELED
> 03/10/2015 13:44:05
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(12/16)
> switched to FINISHED
> 03/10/2015 13:44:05
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(1/16)
> switched to CANCELED
> 03/10/2015 13:44:05
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(10/16)
> switched to FINISHED
> 03/10/2015 13:44:05
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(6/16)
> switched to CANCELED
> 03/10/2015 13:44:05
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(8/16)
> switched to CANCELED
> 03/10/2015 13:44:05
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(4/16)
> switched to CANCELED
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(2/16) switched to CANCELED
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(3/16) switched to CANCELED
> 03/10/2015 13:44:05
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b
> )(9/16)
> switched to CANCELED
> 03/10/2015 13:44:05     Job execution switched to status FAILED.
> 03/10/2015 13:44:05     Job execution switched to status RUNNING.
> 03/10/2015 13:44:05     DataSource (at
> getLongLongVertexData(TestGraphUtils.java:37)
> (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to
> SCHEDULED
> 03/10/2015 13:44:05     DataSource (at
> getLongLongVertexData(TestGraphUtils.java:37)
> (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to
> DEPLOYING
> 03/10/2015 13:44:05     DataSource (at
> getLongLongEdgeInvalidTrgData(TestGraphUtils.java:63)
> (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to
> SCHEDULED
> 03/10/2015 13:44:05     DataSource (at
> getLongLongEdgeInvalidTrgData(TestGraphUtils.java:63)
> (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to
> DEPLOYING
> 03/10/2015 13:44:05     DataSource (at
> getLongLongVertexData(TestGraphUtils.java:37)
> (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to
> RUNNING
> 03/10/2015 13:44:05     DataSource (at
> getLongLongEdgeInvalidTrgData(TestGraphUtils.java:63)
> (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to
> RUNNING
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(1/16) switched to SCHEDULED
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(2/16) switched to SCHEDULED
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(3/16) switched to SCHEDULED
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(4/16) switched to SCHEDULED
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(5/16) switched to SCHEDULED
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(6/16) switched to SCHEDULED
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(7/16) switched to SCHEDULED
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(8/16) switched to SCHEDULED
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(9/16) switched to SCHEDULED
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(10/16) switched to SCHEDULED
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(11/16) switched to SCHEDULED
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(12/16) switched to SCHEDULED
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(13/16) switched to SCHEDULED
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(14/16) switched to SCHEDULED
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(15/16) switched to SCHEDULED
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(16/16) switched to SCHEDULED
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(1/16) switched to DEPLOYING
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(16/16) switched to DEPLOYING
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(15/16) switched to DEPLOYING
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(14/16) switched to DEPLOYING
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(13/16) switched to DEPLOYING
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(12/16) switched to DEPLOYING
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(11/16) switched to DEPLOYING
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(10/16) switched to DEPLOYING
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(9/16) switched to DEPLOYING
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(8/16) switched to DEPLOYING
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(7/16) switched to DEPLOYING
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(6/16) switched to DEPLOYING
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(5/16) switched to DEPLOYING
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(4/16) switched to DEPLOYING
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(3/16) switched to DEPLOYING
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(2/16) switched to DEPLOYING
> Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 5.853
> sec - in org.apache.flink.graph.test.example.LabelPropagationExampleITCase
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(2/16) switched to RUNNING
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(3/16) switched to RUNNING
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(4/16) switched to RUNNING
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(5/16) switched to RUNNING
> 03/10/2015 13:44:05
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(2/16)
> switched to SCHEDULED
> 03/10/2015 13:44:05
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(2/16)
> switched to DEPLOYING
> 03/10/2015 13:44:05
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(3/16)
> switched to SCHEDULED
> 03/10/2015 13:44:05
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(3/16)
> switched to DEPLOYING
> 03/10/2015 13:44:05
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(4/16)
> switched to SCHEDULED
> 03/10/2015 13:44:05
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(4/16)
> switched to DEPLOYING
> 03/10/2015 13:44:05
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(5/16)
> switched to SCHEDULED
> 03/10/2015 13:44:05
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(5/16)
> switched to DEPLOYING
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(6/16) switched to RUNNING
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(7/16) switched to RUNNING
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(9/16) switched to RUNNING
> 03/10/2015 13:44:05     DataSource (at
> getLongLongEdgeInvalidTrgData(TestGraphUtils.java:63)
> (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to
> FINISHED
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(8/16) switched to RUNNING
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(10/16) switched to RUNNING
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(11/16) switched to RUNNING
> 03/10/2015 13:44:05     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(12/16) switched to RUNNING
> 03/10/2015 13:44:06     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(13/16) switched to RUNNING
> 03/10/2015 13:44:06     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(14/16) switched to RUNNING
> 03/10/2015 13:44:06     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(15/16) switched to RUNNING
> 03/10/2015 13:44:06     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(16/16) switched to RUNNING
> 03/10/2015 13:44:06     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(1/16) switched to RUNNING
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(2/16)
> switched to RUNNING
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(3/16)
> switched to RUNNING
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(4/16)
> switched to RUNNING
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(5/16)
> switched to RUNNING
> Running org.apache.flink.graph.test.WeaklyConnectedITCase
> 03/10/2015 13:44:06     DataSource (at
> getLongLongVertexData(TestGraphUtils.java:37)
> (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to
> FINISHED
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(6/16)
> switched to SCHEDULED
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(6/16)
> switched to DEPLOYING
> 03/10/2015 13:44:06     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(5/16) switched to FINISHED
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(4/16)
> switched to FINISHED
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(1/16)
> switched to SCHEDULED
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(1/16)
> switched to DEPLOYING
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(16/16)
> switched to SCHEDULED
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(16/16)
> switched to DEPLOYING
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(7/16)
> switched to SCHEDULED
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(7/16)
> switched to DEPLOYING
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(10/16)
> switched to SCHEDULED
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(13/16)
> switched to SCHEDULED
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(13/16)
> switched to DEPLOYING
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(14/16)
> switched to SCHEDULED
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(14/16)
> switched to DEPLOYING
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(8/16)
> switched to SCHEDULED
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(8/16)
> switched to DEPLOYING
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(15/16)
> switched to SCHEDULED
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(15/16)
> switched to DEPLOYING
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(11/16)
> switched to SCHEDULED
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(11/16)
> switched to DEPLOYING
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(12/16)
> switched to SCHEDULED
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(12/16)
> switched to DEPLOYING
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(10/16)
> switched to DEPLOYING
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(3/16)
> switched to FINISHED
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(7/16)
> switched to RUNNING
> 03/10/2015 13:44:06     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(2/16) switched to FINISHED
> 03/10/2015 13:44:06     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(4/16) switched to FINISHED
> 03/10/2015 13:44:06     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(3/16) switched to FINISHED
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(7/16)
> switched to FINISHED
> 03/10/2015 13:44:06     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(8/16) switched to FINISHED
> 03/10/2015 13:44:06     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(16/16) switched to FINISHED
> 03/10/2015 13:44:06     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(1/16) switched to FINISHED
> 03/10/2015 13:44:06     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(15/16) switched to FINISHED
> 03/10/2015 13:44:06     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(12/16) switched to FINISHED
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(2/16)
> switched to FINISHED
> 03/10/2015 13:44:06     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(11/16) switched to FINISHED
> 03/10/2015 13:44:06     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(7/16) switched to FINISHED
> 03/10/2015 13:44:06     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(10/16) switched to FINISHED
> 03/10/2015 13:44:06     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(13/16) switched to FINISHED
> 03/10/2015 13:44:06     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(14/16) switched to FINISHED
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(10/16)
> switched to RUNNING
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(12/16)
> switched to RUNNING
> 03/10/2015 13:44:06     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(6/16) switched to FINISHED
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(11/16)
> switched to RUNNING
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(15/16)
> switched to RUNNING
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(8/16)
> switched to RUNNING
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(14/16)
> switched to RUNNING
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(13/16)
> switched to RUNNING
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(16/16)
> switched to RUNNING
> 03/10/2015 13:44:06     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(9/16) switched to FAILED
> java.util.NoSuchElementException: The edge src/trg id could not be
> found within the vertexIds
>         at
> org.apache.flink.graph.Graph$CountNeighborsCoGroup.coGroup(Graph.java:643)
>         at
> org.apache.flink.runtime.operators.CoGroupDriver.run(CoGroupDriver.java:152)
>         at
> org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:496)
>         at
> org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:362)
>         at
> org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:205)
>         at java.lang.Thread.run(Thread.java:701)
>
> 03/10/2015 13:44:06     Job execution switched to status FAILING.
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(1/16)
> switched to CANCELING
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(5/16)
> switched to CANCELING
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(6/16)
> switched to CANCELING
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(8/16)
> switched to CANCELING
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(9/16)
> switched to CANCELED
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(10/16)
> switched to CANCELING
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(11/16)
> switched to CANCELING
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(12/16)
> switched to CANCELING
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(13/16)
> switched to CANCELING
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(14/16)
> switched to CANCELING
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(15/16)
> switched to CANCELING
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(16/16)
> switched to CANCELING
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(5/16)
> switched to CANCELED
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(15/16)
> switched to CANCELED
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(11/16)
> switched to CANCELED
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(12/16)
> switched to CANCELED
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(16/16)
> switched to CANCELED
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(1/16)
> switched to CANCELED
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(10/16)
> switched to CANCELED
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(8/16)
> switched to CANCELED
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(14/16)
> switched to CANCELED
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(13/16)
> switched to CANCELED
> 03/10/2015 13:44:06
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9
> )(6/16)
> switched to CANCELED
> 03/10/2015 13:44:06     Job execution switched to status FAILED.
> 03/10/2015 13:44:07     Job execution switched to status RUNNING.
> 03/10/2015 13:44:07     DataSource (at
> getLongLongEdgeInvalidSrcData(TestGraphUtils.java:53)
> (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to
> SCHEDULED
> 03/10/2015 13:44:07     DataSource (at
> getLongLongEdgeInvalidSrcData(TestGraphUtils.java:53)
> (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to
> DEPLOYING
> 03/10/2015 13:44:07     DataSource (at
> getLongLongVertexData(TestGraphUtils.java:37)
> (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to
> SCHEDULED
> 03/10/2015 13:44:07     DataSource (at
> getLongLongVertexData(TestGraphUtils.java:37)
> (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to
> DEPLOYING
> 03/10/2015 13:44:07     DataSource (at
> getLongLongEdgeInvalidSrcData(TestGraphUtils.java:53)
> (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to
> RUNNING
> 03/10/2015 13:44:07     DataSource (at
> getLongLongVertexData(TestGraphUtils.java:37)
> (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to
> RUNNING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(1/16) switched to SCHEDULED
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(1/16) switched to DEPLOYING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(2/16) switched to SCHEDULED
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(2/16) switched to DEPLOYING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(3/16) switched to SCHEDULED
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(3/16) switched to DEPLOYING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(4/16) switched to SCHEDULED
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(4/16) switched to DEPLOYING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(5/16) switched to SCHEDULED
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(5/16) switched to DEPLOYING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(6/16) switched to SCHEDULED
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(6/16) switched to DEPLOYING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(7/16) switched to SCHEDULED
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(7/16) switched to DEPLOYING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(8/16) switched to SCHEDULED
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(8/16) switched to DEPLOYING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(9/16) switched to SCHEDULED
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(9/16) switched to DEPLOYING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(10/16) switched to SCHEDULED
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(10/16) switched to DEPLOYING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(11/16) switched to SCHEDULED
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(11/16) switched to DEPLOYING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(12/16) switched to SCHEDULED
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(12/16) switched to DEPLOYING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(13/16) switched to SCHEDULED
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(13/16) switched to DEPLOYING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(14/16) switched to SCHEDULED
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(15/16) switched to SCHEDULED
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(14/16) switched to DEPLOYING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(15/16) switched to DEPLOYING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(16/16) switched to SCHEDULED
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(16/16) switched to DEPLOYING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(1/16) switched to SCHEDULED
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(1/16) switched to DEPLOYING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(2/16) switched to SCHEDULED
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(2/16) switched to DEPLOYING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(3/16) switched to SCHEDULED
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(4/16) switched to SCHEDULED
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(3/16) switched to DEPLOYING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(4/16) switched to DEPLOYING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(5/16) switched to SCHEDULED
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(5/16) switched to DEPLOYING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(6/16) switched to SCHEDULED
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(6/16) switched to DEPLOYING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(7/16) switched to SCHEDULED
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(7/16) switched to DEPLOYING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(8/16) switched to SCHEDULED
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(8/16) switched to DEPLOYING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(9/16) switched to SCHEDULED
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(9/16) switched to DEPLOYING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(10/16) switched to SCHEDULED
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(10/16) switched to DEPLOYING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(11/16) switched to SCHEDULED
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(11/16) switched to DEPLOYING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(12/16) switched to SCHEDULED
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(12/16) switched to DEPLOYING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(13/16) switched to SCHEDULED
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(13/16) switched to DEPLOYING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(14/16) switched to SCHEDULED
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(14/16) switched to DEPLOYING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(15/16) switched to SCHEDULED
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(15/16) switched to DEPLOYING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(16/16) switched to SCHEDULED
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(16/16) switched to DEPLOYING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(16/16) switched to RUNNING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(15/16) switched to RUNNING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(1/16) switched to RUNNING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(2/16) switched to RUNNING
> 03/10/2015 13:44:07     Reduce(SUM(1), at getDegrees(Graph.java:664)(1/16)
> switched to SCHEDULED
> 03/10/2015 13:44:07     Reduce(SUM(1), at getDegrees(Graph.java:664)(1/16)
> switched to DEPLOYING
> 03/10/2015 13:44:07     Reduce(SUM(1), at getDegrees(Graph.java:664)(2/16)
> switched to SCHEDULED
> 03/10/2015 13:44:07     Reduce(SUM(1), at getDegrees(Graph.java:664)(2/16)
> switched to DEPLOYING
> 03/10/2015 13:44:07     Reduce(SUM(1), at getDegrees(Graph.java:664)(3/16)
> switched to SCHEDULED
> 03/10/2015 13:44:07     Reduce(SUM(1), at getDegrees(Graph.java:664)(3/16)
> switched to DEPLOYING
> 03/10/2015 13:44:07     Reduce(SUM(1), at getDegrees(Graph.java:664)(4/16)
> switched to SCHEDULED
> 03/10/2015 13:44:07     Reduce(SUM(1), at getDegrees(Graph.java:664)(4/16)
> switched to DEPLOYING
> 03/10/2015 13:44:07     Reduce(SUM(1), at getDegrees(Graph.java:664)(5/16)
> switched to SCHEDULED
> 03/10/2015 13:44:07     Reduce(SUM(1), at getDegrees(Graph.java:664)(5/16)
> switched to DEPLOYING
> 03/10/2015 13:44:07     Reduce(SUM(1), at getDegrees(Graph.java:664)(6/16)
> switched to SCHEDULED
> 03/10/2015 13:44:07     Reduce(SUM(1), at getDegrees(Graph.java:664)(6/16)
> switched to DEPLOYING
> 03/10/2015 13:44:07     Reduce(SUM(1), at getDegrees(Graph.java:664)(7/16)
> switched to SCHEDULED
> 03/10/2015 13:44:07     Reduce(SUM(1), at getDegrees(Graph.java:664)(7/16)
> switched to DEPLOYING
> 03/10/2015 13:44:07     Reduce(SUM(1), at getDegrees(Graph.java:664)(8/16)
> switched to SCHEDULED
> 03/10/2015 13:44:07     Reduce(SUM(1), at getDegrees(Graph.java:664)(8/16)
> switched to DEPLOYING
> 03/10/2015 13:44:07     Reduce(SUM(1), at getDegrees(Graph.java:664)(9/16)
> switched to SCHEDULED
> 03/10/2015 13:44:07     Reduce(SUM(1), at getDegrees(Graph.java:664)(9/16)
> switched to DEPLOYING
> 03/10/2015 13:44:07     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(10/16) switched to SCHEDULED
> 03/10/2015 13:44:07     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(10/16) switched to DEPLOYING
> 03/10/2015 13:44:07     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(11/16) switched to SCHEDULED
> 03/10/2015 13:44:07     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(12/16) switched to SCHEDULED
> 03/10/2015 13:44:07     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(11/16) switched to DEPLOYING
> 03/10/2015 13:44:07     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(12/16) switched to DEPLOYING
> 03/10/2015 13:44:07     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(13/16) switched to SCHEDULED
> 03/10/2015 13:44:07     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(14/16) switched to SCHEDULED
> 03/10/2015 13:44:07     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(13/16) switched to DEPLOYING
> 03/10/2015 13:44:07     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(15/16) switched to SCHEDULED
> 03/10/2015 13:44:07     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(15/16) switched to DEPLOYING
> 03/10/2015 13:44:07     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(16/16) switched to SCHEDULED
> 03/10/2015 13:44:07     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(16/16) switched to DEPLOYING
> 03/10/2015 13:44:07     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(14/16) switched to DEPLOYING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(4/16) switched to RUNNING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(5/16) switched to RUNNING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(6/16) switched to RUNNING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(7/16) switched to RUNNING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(8/16) switched to RUNNING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(9/16) switched to RUNNING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(10/16) switched to RUNNING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(11/16) switched to RUNNING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(12/16) switched to RUNNING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(13/16) switched to RUNNING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(14/16) switched to RUNNING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(15/16) switched to RUNNING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(16/16) switched to RUNNING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(14/16) switched to RUNNING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(13/16) switched to RUNNING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(12/16) switched to RUNNING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(11/16) switched to RUNNING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(10/16) switched to RUNNING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(9/16) switched to RUNNING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(8/16) switched to RUNNING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(7/16) switched to RUNNING
> 03/10/2015 13:44:07     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(6/16) switched to RUNNING
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(5/16) switched to RUNNING
> 03/10/2015 13:44:08     DataSource (at
> getLongLongVertexData(TestGraphUtils.java:37)
> (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to
> FINISHED
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(4/16) switched to RUNNING
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(3/16) switched to RUNNING
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(2/16) switched to RUNNING
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(1/16) switched to RUNNING
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(3/16) switched to RUNNING
> 03/10/2015 13:44:08     DataSource (at
> getLongLongEdgeInvalidSrcData(TestGraphUtils.java:53)
> (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to
> FINISHED
> 03/10/2015 13:44:08     Reduce(SUM(1), at getDegrees(Graph.java:664)(1/16)
> switched to RUNNING
> 03/10/2015 13:44:08     Reduce(SUM(1), at getDegrees(Graph.java:664)(2/16)
> switched to RUNNING
> 03/10/2015 13:44:08     Reduce(SUM(1), at getDegrees(Graph.java:664)(3/16)
> switched to RUNNING
> 03/10/2015 13:44:08     Reduce(SUM(1), at getDegrees(Graph.java:664)(4/16)
> switched to RUNNING
> 03/10/2015 13:44:08     Reduce(SUM(1), at getDegrees(Graph.java:664)(5/16)
> switched to RUNNING
> 03/10/2015 13:44:08     Reduce(SUM(1), at getDegrees(Graph.java:664)(6/16)
> switched to RUNNING
> 03/10/2015 13:44:08     Reduce(SUM(1), at getDegrees(Graph.java:664)(7/16)
> switched to RUNNING
> 03/10/2015 13:44:08     Reduce(SUM(1), at getDegrees(Graph.java:664)(8/16)
> switched to RUNNING
> 03/10/2015 13:44:08     Reduce(SUM(1), at getDegrees(Graph.java:664)(9/16)
> switched to RUNNING
> 03/10/2015 13:44:08     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(11/16) switched to RUNNING
> 03/10/2015 13:44:08     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(12/16) switched to RUNNING
> 03/10/2015 13:44:08     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(13/16) switched to RUNNING
> 03/10/2015 13:44:08     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(10/16) switched to RUNNING
> 03/10/2015 13:44:08     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(16/16) switched to RUNNING
> 03/10/2015 13:44:08     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(15/16) switched to RUNNING
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(2/16) switched to FINISHED
> 03/10/2015 13:44:08     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(14/16) switched to RUNNING
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(1/16) switched to FINISHED
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(16/16) switched to FINISHED
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(4/16) switched to FINISHED
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(15/16) switched to FINISHED
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(6/16) switched to FINISHED
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(8/16) switched to FINISHED
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(10/16) switched to FINISHED
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(9/16) switched to FAILED
> java.util.NoSuchElementException: The edge src/trg id could not be
> found within the vertexIds
>         at
> org.apache.flink.graph.Graph$CountNeighborsCoGroup.coGroup(Graph.java:643)
>         at
> org.apache.flink.runtime.operators.CoGroupDriver.run(CoGroupDriver.java:152)
>         at
> org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:496)
>         at
> org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:362)
>         at
> org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:205)
>         at java.lang.Thread.run(Thread.java:701)
>
> 03/10/2015 13:44:08     Job execution switched to status FAILING.
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(1/16) switched to CANCELING
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(2/16) switched to CANCELING
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(3/16) switched to CANCELING
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(4/16) switched to CANCELING
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(5/16) switched to CANCELING
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(7/16) switched to CANCELING
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(11/16) switched to CANCELING
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(12/16) switched to CANCELING
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(13/16) switched to CANCELING
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(14/16) switched to CANCELING
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(3/16) switched to CANCELING
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(5/16) switched to CANCELING
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(6/16) switched to CANCELING
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(7/16) switched to CANCELING
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(8/16) switched to CANCELING
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(9/16) switched to CANCELING
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(10/16) switched to CANCELING
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(11/16) switched to CANCELING
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(12/16) switched to CANCELING
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(13/16) switched to CANCELING
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(14/16) switched to CANCELING
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(15/16) switched to CANCELING
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(16/16) switched to CANCELING
> 03/10/2015 13:44:08     Reduce(SUM(1), at getDegrees(Graph.java:664)(1/16)
> switched to CANCELING
> 03/10/2015 13:44:08     Reduce(SUM(1), at getDegrees(Graph.java:664)(2/16)
> switched to CANCELING
> 03/10/2015 13:44:08     Reduce(SUM(1), at getDegrees(Graph.java:664)(3/16)
> switched to CANCELING
> 03/10/2015 13:44:08     Reduce(SUM(1), at getDegrees(Graph.java:664)(4/16)
> switched to CANCELING
> 03/10/2015 13:44:08     Reduce(SUM(1), at getDegrees(Graph.java:664)(5/16)
> switched to CANCELING
> 03/10/2015 13:44:08     Reduce(SUM(1), at getDegrees(Graph.java:664)(6/16)
> switched to CANCELING
> 03/10/2015 13:44:08     Reduce(SUM(1), at getDegrees(Graph.java:664)(7/16)
> switched to CANCELING
> 03/10/2015 13:44:08     Reduce(SUM(1), at getDegrees(Graph.java:664)(8/16)
> switched to CANCELING
> 03/10/2015 13:44:08     Reduce(SUM(1), at getDegrees(Graph.java:664)(9/16)
> switched to CANCELING
> 03/10/2015 13:44:08     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(10/16) switched to CANCELING
> 03/10/2015 13:44:08     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(11/16) switched to CANCELING
> 03/10/2015 13:44:08     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(12/16) switched to CANCELING
> 03/10/2015 13:44:08     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(13/16) switched to CANCELING
> 03/10/2015 13:44:08     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(14/16) switched to CANCELING
> 03/10/2015 13:44:08     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(15/16) switched to CANCELING
> 03/10/2015 13:44:08     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(16/16) switched to CANCELING
> 03/10/2015 13:44:08
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a44efd4
> )(1/16)
> switched to CANCELED
> 03/10/2015 13:44:08
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a44efd4
> )(2/16)
> switched to CANCELED
> 03/10/2015 13:44:08
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a44efd4
> )(3/16)
> switched to CANCELED
> 03/10/2015 13:44:08
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a44efd4
> )(4/16)
> switched to CANCELED
> 03/10/2015 13:44:08
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a44efd4
> )(5/16)
> switched to CANCELED
> 03/10/2015 13:44:08
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a44efd4
> )(6/16)
> switched to CANCELED
> 03/10/2015 13:44:08
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a44efd4
> )(7/16)
> switched to CANCELED
> 03/10/2015 13:44:08
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a44efd4
> )(8/16)
> switched to CANCELED
> 03/10/2015 13:44:08
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a44efd4
> )(9/16)
> switched to CANCELED
> 03/10/2015 13:44:08
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a44efd4
> )(10/16)
> switched to CANCELED
> 03/10/2015 13:44:08
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a44efd4
> )(11/16)
> switched to CANCELED
> 03/10/2015 13:44:08
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a44efd4
> )(12/16)
> switched to CANCELED
> 03/10/2015 13:44:08
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a44efd4
> )(13/16)
> switched to CANCELED
> 03/10/2015 13:44:08
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a44efd4
> )(14/16)
> switched to CANCELED
> 03/10/2015 13:44:08
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a44efd4
> )(15/16)
> switched to CANCELED
> 03/10/2015 13:44:08
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a44efd4
> )(16/16)
> switched to CANCELED
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(11/16) switched to CANCELED
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(11/16) switched to CANCELED
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(10/16) switched to CANCELED
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(13/16) switched to CANCELED
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(16/16) switched to CANCELED
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(7/16) switched to CANCELED
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(9/16) switched to CANCELED
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(14/16) switched to CANCELED
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(8/16) switched to CANCELED
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(12/16) switched to CANCELED
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(13/16) switched to CANCELED
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(7/16) switched to CANCELED
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(3/16) switched to CANCELED
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(1/16) switched to CANCELED
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(2/16) switched to CANCELED
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(3/16) switched to CANCELED
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(4/16) switched to CANCELED
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(5/16) switched to CANCELED
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(14/16) switched to CANCELED
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(15/16) switched to CANCELED
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(12/16) switched to CANCELED
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(5/16) switched to CANCELED
> 03/10/2015 13:44:08     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(6/16) switched to CANCELED
> 03/10/2015 13:44:08     Reduce(SUM(1), at getDegrees(Graph.java:664)(1/16)
> switched to CANCELED
> 03/10/2015 13:44:08     Reduce(SUM(1), at getDegrees(Graph.java:664)(2/16)
> switched to CANCELED
> 03/10/2015 13:44:08     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(15/16) switched to CANCELED
> 03/10/2015 13:44:08     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(16/16) switched to CANCELED
> 03/10/2015 13:44:08     Reduce(SUM(1), at getDegrees(Graph.java:664)(3/16)
> switched to CANCELED
> 03/10/2015 13:44:08     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(14/16) switched to CANCELED
> 03/10/2015 13:44:08     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(13/16) switched to CANCELED
> 03/10/2015 13:44:08     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(12/16) switched to CANCELED
> 03/10/2015 13:44:08     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(11/16) switched to CANCELED
> 03/10/2015 13:44:08     Reduce(SUM(1), at getDegrees(Graph.java:664)(9/16)
> switched to CANCELED
> 03/10/2015 13:44:08     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(10/16) switched to CANCELED
> 03/10/2015 13:44:08     Reduce(SUM(1), at getDegrees(Graph.java:664)(8/16)
> switched to CANCELED
> 03/10/2015 13:44:08     Reduce(SUM(1), at getDegrees(Graph.java:664)(5/16)
> switched to CANCELED
> 03/10/2015 13:44:08     Reduce(SUM(1), at getDegrees(Graph.java:664)(4/16)
> switched to CANCELED
> 03/10/2015 13:44:08     Reduce(SUM(1), at getDegrees(Graph.java:664)(7/16)
> switched to CANCELED
> 03/10/2015 13:44:08     Reduce(SUM(1), at getDegrees(Graph.java:664)(6/16)
> switched to CANCELED
> 03/10/2015 13:44:08     Job execution switched to status FAILED.
> 03/10/2015 13:44:09     Job execution switched to status RUNNING.
> 03/10/2015 13:44:09     DataSource (at
> getLongLongVertexData(TestGraphUtils.java:37)
> (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to
> SCHEDULED
> 03/10/2015 13:44:09     DataSource (at
> getLongLongVertexData(TestGraphUtils.java:37)
> (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to
> DEPLOYING
> 03/10/2015 13:44:09     DataSource (at
> getLongLongEdgeInvalidTrgData(TestGraphUtils.java:63)
> (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to
> SCHEDULED
> 03/10/2015 13:44:09     DataSource (at
> getLongLongEdgeInvalidTrgData(TestGraphUtils.java:63)
> (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to
> DEPLOYING
> 03/10/2015 13:44:09     DataSource (at
> getLongLongVertexData(TestGraphUtils.java:37)
> (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to
> RUNNING
> 03/10/2015 13:44:09     DataSource (at
> getLongLongEdgeInvalidTrgData(TestGraphUtils.java:63)
> (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to
> RUNNING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(1/16) switched to SCHEDULED
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(1/16) switched to DEPLOYING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(2/16) switched to SCHEDULED
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(3/16) switched to SCHEDULED
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(2/16) switched to DEPLOYING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(3/16) switched to DEPLOYING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(4/16) switched to SCHEDULED
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(5/16) switched to SCHEDULED
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(4/16) switched to DEPLOYING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(5/16) switched to DEPLOYING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(6/16) switched to SCHEDULED
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(7/16) switched to SCHEDULED
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(6/16) switched to DEPLOYING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(7/16) switched to DEPLOYING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(8/16) switched to SCHEDULED
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(9/16) switched to SCHEDULED
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(8/16) switched to DEPLOYING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(9/16) switched to DEPLOYING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(10/16) switched to SCHEDULED
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(11/16) switched to SCHEDULED
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(10/16) switched to DEPLOYING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(11/16) switched to DEPLOYING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(12/16) switched to SCHEDULED
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(13/16) switched to SCHEDULED
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(12/16) switched to DEPLOYING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(13/16) switched to DEPLOYING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(14/16) switched to SCHEDULED
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(15/16) switched to SCHEDULED
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(14/16) switched to DEPLOYING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(15/16) switched to DEPLOYING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(16/16) switched to SCHEDULED
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(1/16) switched to SCHEDULED
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(16/16) switched to DEPLOYING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(1/16) switched to DEPLOYING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(2/16) switched to SCHEDULED
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(3/16) switched to SCHEDULED
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(2/16) switched to DEPLOYING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(3/16) switched to DEPLOYING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(4/16) switched to SCHEDULED
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(5/16) switched to SCHEDULED
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(4/16) switched to DEPLOYING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(5/16) switched to DEPLOYING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(6/16) switched to SCHEDULED
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(7/16) switched to SCHEDULED
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(6/16) switched to DEPLOYING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(7/16) switched to DEPLOYING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(8/16) switched to SCHEDULED
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(9/16) switched to SCHEDULED
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(8/16) switched to DEPLOYING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(9/16) switched to DEPLOYING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(10/16) switched to SCHEDULED
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(11/16) switched to SCHEDULED
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(10/16) switched to DEPLOYING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(11/16) switched to DEPLOYING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(12/16) switched to SCHEDULED
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(13/16) switched to SCHEDULED
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(12/16) switched to DEPLOYING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(13/16) switched to DEPLOYING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(14/16) switched to SCHEDULED
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(15/16) switched to SCHEDULED
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(14/16) switched to DEPLOYING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(15/16) switched to DEPLOYING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(16/16) switched to SCHEDULED
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(16/16) switched to DEPLOYING
> 03/10/2015 13:44:09     DataSource (at
> getLongLongEdgeInvalidTrgData(TestGraphUtils.java:63)
> (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to
> FINISHED
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(1/16) switched to RUNNING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(2/16) switched to RUNNING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(3/16) switched to RUNNING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(4/16) switched to RUNNING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(5/16) switched to RUNNING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(6/16) switched to RUNNING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(7/16) switched to RUNNING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(8/16) switched to RUNNING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(9/16) switched to RUNNING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(10/16) switched to RUNNING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(11/16) switched to RUNNING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(12/16) switched to RUNNING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(13/16) switched to RUNNING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(14/16) switched to RUNNING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(15/16) switched to RUNNING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(16/16) switched to RUNNING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(1/16) switched to RUNNING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(2/16) switched to RUNNING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(3/16) switched to RUNNING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(4/16) switched to RUNNING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(5/16) switched to RUNNING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(6/16) switched to RUNNING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(7/16) switched to RUNNING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(8/16) switched to RUNNING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(9/16) switched to RUNNING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(10/16) switched to RUNNING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(11/16) switched to RUNNING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(12/16) switched to RUNNING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(13/16) switched to RUNNING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(15/16) switched to RUNNING
> 03/10/2015 13:44:09     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(16/16) switched to RUNNING
> 03/10/2015 13:44:10     Reduce(SUM(1), at getDegrees(Graph.java:664)(1/16)
> switched to SCHEDULED
> 03/10/2015 13:44:10     Reduce(SUM(1), at getDegrees(Graph.java:664)(1/16)
> switched to DEPLOYING
> 03/10/2015 13:44:10     Reduce(SUM(1), at getDegrees(Graph.java:664)(2/16)
> switched to SCHEDULED
> 03/10/2015 13:44:10     Reduce(SUM(1), at getDegrees(Graph.java:664)(2/16)
> switched to DEPLOYING
> 03/10/2015 13:44:10     Reduce(SUM(1), at getDegrees(Graph.java:664)(3/16)
> switched to SCHEDULED
> 03/10/2015 13:44:10     Reduce(SUM(1), at getDegrees(Graph.java:664)(3/16)
> switched to DEPLOYING
> 03/10/2015 13:44:10     Reduce(SUM(1), at getDegrees(Graph.java:664)(4/16)
> switched to SCHEDULED
> 03/10/2015 13:44:10     Reduce(SUM(1), at getDegrees(Graph.java:664)(4/16)
> switched to DEPLOYING
> 03/10/2015 13:44:10     Reduce(SUM(1), at getDegrees(Graph.java:664)(5/16)
> switched to SCHEDULED
> 03/10/2015 13:44:10     Reduce(SUM(1), at getDegrees(Graph.java:664)(6/16)
> switched to SCHEDULED
> 03/10/2015 13:44:10     Reduce(SUM(1), at getDegrees(Graph.java:664)(5/16)
> switched to DEPLOYING
> 03/10/2015 13:44:10     Reduce(SUM(1), at getDegrees(Graph.java:664)(6/16)
> switched to DEPLOYING
> 03/10/2015 13:44:10     Reduce(SUM(1), at getDegrees(Graph.java:664)(7/16)
> switched to SCHEDULED
> 03/10/2015 13:44:10     Reduce(SUM(1), at getDegrees(Graph.java:664)(7/16)
> switched to DEPLOYING
> 03/10/2015 13:44:10     Reduce(SUM(1), at getDegrees(Graph.java:664)(8/16)
> switched to SCHEDULED
> 03/10/2015 13:44:10     Reduce(SUM(1), at getDegrees(Graph.java:664)(9/16)
> switched to SCHEDULED
> 03/10/2015 13:44:10     Reduce(SUM(1), at getDegrees(Graph.java:664)(8/16)
> switched to DEPLOYING
> 03/10/2015 13:44:10     Reduce(SUM(1), at getDegrees(Graph.java:664)(9/16)
> switched to DEPLOYING
> 03/10/2015 13:44:10     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(10/16) switched to SCHEDULED
> 03/10/2015 13:44:10     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(10/16) switched to DEPLOYING
> 03/10/2015 13:44:10     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(11/16) switched to SCHEDULED
> 03/10/2015 13:44:10     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(12/16) switched to SCHEDULED
> 03/10/2015 13:44:10     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(11/16) switched to DEPLOYING
> 03/10/2015 13:44:10     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(12/16) switched to DEPLOYING
> 03/10/2015 13:44:10     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(13/16) switched to SCHEDULED
> 03/10/2015 13:44:10     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(13/16) switched to DEPLOYING
> 03/10/2015 13:44:10     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(14/16) switched to SCHEDULED
> 03/10/2015 13:44:10     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(14/16) switched to DEPLOYING
> 03/10/2015 13:44:10     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(15/16) switched to SCHEDULED
> 03/10/2015 13:44:10     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(15/16) switched to DEPLOYING
> 03/10/2015 13:44:10     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(16/16) switched to SCHEDULED
> 03/10/2015 13:44:10     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(16/16) switched to DEPLOYING
> 03/10/2015 13:44:10     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(14/16) switched to RUNNING
> 03/10/2015 13:44:10     Reduce(SUM(1), at getDegrees(Graph.java:664)(1/16)
> switched to RUNNING
> 03/10/2015 13:44:10     Reduce(SUM(1), at getDegrees(Graph.java:664)(2/16)
> switched to RUNNING
> 03/10/2015 13:44:10     Reduce(SUM(1), at getDegrees(Graph.java:664)(3/16)
> switched to RUNNING
> 03/10/2015 13:44:10     Reduce(SUM(1), at getDegrees(Graph.java:664)(4/16)
> switched to RUNNING
> 03/10/2015 13:44:10     Reduce(SUM(1), at getDegrees(Graph.java:664)(5/16)
> switched to RUNNING
> 03/10/2015 13:44:10     Reduce(SUM(1), at getDegrees(Graph.java:664)(7/16)
> switched to RUNNING
> 03/10/2015 13:44:10     Reduce(SUM(1), at getDegrees(Graph.java:664)(8/16)
> switched to RUNNING
> 03/10/2015 13:44:10     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(10/16) switched to RUNNING
> 03/10/2015 13:44:10     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(11/16) switched to RUNNING
> 03/10/2015 13:44:10     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(13/16) switched to RUNNING
> 03/10/2015 13:44:10     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(14/16) switched to RUNNING
> 03/10/2015 13:44:10     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(15/16) switched to RUNNING
> 03/10/2015 13:44:10     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(16/16) switched to RUNNING
> 03/10/2015 13:44:10     Reduce(SUM(1), at getDegrees(Graph.java:664)(6/16)
> switched to RUNNING
> 03/10/2015 13:44:10     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(12/16) switched to RUNNING
> 03/10/2015 13:44:10     Reduce(SUM(1), at getDegrees(Graph.java:664)(9/16)
> switched to RUNNING
> 03/10/2015 13:44:10     DataSource (at
> getLongLongVertexData(TestGraphUtils.java:37)
> (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to
> FINISHED
> 03/10/2015 13:44:10     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(10/16) switched to FINISHED
> 03/10/2015 13:44:10     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(8/16) switched to FINISHED
> 03/10/2015 13:44:10     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(7/16) switched to FINISHED
> 03/10/2015 13:44:10     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(5/16) switched to FINISHED
> 03/10/2015 13:44:10     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(2/16) switched to FINISHED
> 03/10/2015 13:44:10     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(3/16) switched to FINISHED
> 03/10/2015 13:44:10     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(1/16) switched to FINISHED
> 03/10/2015 13:44:10     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(16/16) switched to FINISHED
> 03/10/2015 13:44:10     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(15/16) switched to FINISHED
> 03/10/2015 13:44:10     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(13/16) switched to FINISHED
> 03/10/2015 13:44:10     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(10/16) switched to FINISHED
> 03/10/2015 13:44:10     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(7/16) switched to FINISHED
> 03/10/2015 13:44:10     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(3/16) switched to FINISHED
> 03/10/2015 13:44:10     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(4/16) switched to FINISHED
> 03/10/2015 13:44:10     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(2/16) switched to FINISHED
> 03/10/2015 13:44:10     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(11/16) switched to FINISHED
> 03/10/2015 13:44:10     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(6/16) switched to FINISHED
> 03/10/2015 13:44:10     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(16/16) switched to FINISHED
> 03/10/2015 13:44:10     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(1/16) switched to FINISHED
> 03/10/2015 13:44:10     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(5/16) switched to FINISHED
> 03/10/2015 13:44:10     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(8/16) switched to FINISHED
> 03/10/2015 13:44:10     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(12/16) switched to FINISHED
> 03/10/2015 13:44:10     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(14/16) switched to FINISHED
> 03/10/2015 13:44:10     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(13/16) switched to FINISHED
> 03/10/2015 13:44:10     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(9/16) switched to FINISHED
> 03/10/2015 13:44:10     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(11/16) switched to FINISHED
> 03/10/2015 13:44:10     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(6/16) switched to FINISHED
> 03/10/2015 13:44:10     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(12/16) switched to FINISHED
> 03/10/2015 13:44:10     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(4/16) switched to FINISHED
> 03/10/2015 13:44:10     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(9/16) switched to FAILED
> java.util.NoSuchElementException: The edge src/trg id could not be
> found within the vertexIds
>         at
> org.apache.flink.graph.Graph$CountNeighborsCoGroup.coGroup(Graph.java:643)
>         at
> org.apache.flink.runtime.operators.CoGroupDriver.run(CoGroupDriver.java:152)
>         at
> org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:496)
>         at
> org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:362)
>         at
> org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:205)
>         at java.lang.Thread.run(Thread.java:701)
>
> 03/10/2015 13:44:10     Job execution switched to status FAILING.
> 03/10/2015 13:44:10     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(14/16) switched to CANCELING
> 03/10/2015 13:44:10     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(15/16) switched to CANCELING
> 03/10/2015 13:44:10     Reduce(SUM(1), at getDegrees(Graph.java:664)(1/16)
> switched to CANCELING
> 03/10/2015 13:44:10     Reduce(SUM(1), at getDegrees(Graph.java:664)(2/16)
> switched to CANCELING
> 03/10/2015 13:44:10     Reduce(SUM(1), at getDegrees(Graph.java:664)(3/16)
> switched to CANCELING
> 03/10/2015 13:44:10     Reduce(SUM(1), at getDegrees(Graph.java:664)(4/16)
> switched to CANCELING
> 03/10/2015 13:44:10     Reduce(SUM(1), at getDegrees(Graph.java:664)(5/16)
> switched to CANCELING
> 03/10/2015 13:44:10     Reduce(SUM(1), at getDegrees(Graph.java:664)(6/16)
> switched to CANCELING
> 03/10/2015 13:44:10     Reduce(SUM(1), at getDegrees(Graph.java:664)(7/16)
> switched to CANCELING
> 03/10/2015 13:44:10     Reduce(SUM(1), at getDegrees(Graph.java:664)(8/16)
> switched to CANCELING
> 03/10/2015 13:44:10     Reduce(SUM(1), at getDegrees(Graph.java:664)(9/16)
> switched to CANCELING
> 03/10/2015 13:44:10     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(10/16) switched to CANCELING
> 03/10/2015 13:44:10     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(11/16) switched to CANCELING
> 03/10/2015 13:44:10     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(12/16) switched to CANCELING
> 03/10/2015 13:44:10     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(13/16) switched to CANCELING
> 03/10/2015 13:44:10     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(14/16) switched to CANCELING
> 03/10/2015 13:44:10     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(15/16) switched to CANCELING
> 03/10/2015 13:44:10     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(16/16) switched to CANCELING
> 03/10/2015 13:44:10
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a6d476
> )(1/16)
> switched to CANCELED
> 03/10/2015 13:44:10
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a6d476
> )(2/16)
> switched to CANCELED
> 03/10/2015 13:44:10
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a6d476
> )(3/16)
> switched to CANCELED
> 03/10/2015 13:44:10
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a6d476
> )(4/16)
> switched to CANCELED
> 03/10/2015 13:44:10
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a6d476
> )(5/16)
> switched to CANCELED
> 03/10/2015 13:44:10
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a6d476
> )(6/16)
> switched to CANCELED
> 03/10/2015 13:44:10
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a6d476
> )(7/16)
> switched to CANCELED
> 03/10/2015 13:44:10
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a6d476
> )(8/16)
> switched to CANCELED
> 03/10/2015 13:44:10
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a6d476
> )(9/16)
> switched to CANCELED
> 03/10/2015 13:44:10
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a6d476
> )(10/16)
> switched to CANCELED
> 03/10/2015 13:44:10
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a6d476
> )(11/16)
> switched to CANCELED
> 03/10/2015 13:44:10
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a6d476
> )(12/16)
> switched to CANCELED
> 03/10/2015 13:44:10
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a6d476
> )(13/16)
> switched to CANCELED
> 03/10/2015 13:44:10
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a6d476
> )(14/16)
> switched to CANCELED
> 03/10/2015 13:44:10
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a6d476
> )(15/16)
> switched to CANCELED
> 03/10/2015 13:44:10
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a6d476
> )(16/16)
> switched to CANCELED
> 03/10/2015 13:44:10     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(14/16) switched to CANCELED
> 03/10/2015 13:44:10     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(15/16) switched to CANCELED
> 03/10/2015 13:44:10     Reduce(SUM(1), at getDegrees(Graph.java:664)(7/16)
> switched to CANCELED
> 03/10/2015 13:44:10     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(11/16) switched to FAILED
> java.lang.Exception: The data preparation for task 'Reduce(SUM(1), at
> getDegrees(Graph.java:664)' , caused an error: Error obtaining the
> sorted input: Thread 'SortMerger Reading Thread' terminated due to an
> exception: Bug in input gate/channel logic: input gate gotnotified by
> channel about available data, but none was available.
>         at
> org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:471)
>         at
> org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:362)
>         at
> org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:205)
>         at java.lang.Thread.run(Thread.java:701)
> Caused by: java.lang.RuntimeException: Error obtaining the sorted
> input: Thread 'SortMerger Reading Thread' terminated due to an
> exception: Bug in input gate/channel logic: input gate gotnotified by
> channel about available data, but none was available.
>         at
> org.apache.flink.runtime.operators.sort.UnilateralSortMerger.getIterator(UnilateralSortMerger.java:607)
>         at
> org.apache.flink.runtime.operators.RegularPactTask.getInput(RegularPactTask.java:1131)
>         at
> org.apache.flink.runtime.operators.GroupReduceDriver.prepare(GroupReduceDriver.java:94)
>         at
> org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:466)
>         ... 3 more
> Caused by: java.io.IOException: Thread 'SortMerger Reading Thread'
> terminated due to an exception: Bug in input gate/channel logic: input
> gate gotnotified by channel about available data, but none was
> available.
>         at
> org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:784)
> Caused by: java.lang.IllegalStateException: Bug in input gate/channel
> logic: input gate gotnotified by channel about available data, but
> none was available.
>         at
> org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.getNextBufferOrEvent(SingleInputGate.java:314)
>         at
> org.apache.flink.runtime.io.network.partition.consumer.UnionInputGate.getNextBufferOrEvent(UnionInputGate.java:141)
>         at
> org.apache.flink.runtime.io.network.api.reader.AbstractRecordReader.getNextRecord(AbstractRecordReader.java:75)
>         at
> org.apache.flink.runtime.io.network.api.reader.MutableRecordReader.next(MutableRecordReader.java:34)
>         at
> org.apache.flink.runtime.operators.util.ReaderIterator.next(ReaderIterator.java:59)
>         at
> org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ReadingThread.go(UnilateralSortMerger.java:958)
>         at
> org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:781)
>
> 03/10/2015 13:44:10     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(12/16) switched to FAILED
> java.lang.Exception: The data preparation for task 'Reduce(SUM(1), at
> getDegrees(Graph.java:664)' , caused an error: Error obtaining the
> sorted input: Thread 'SortMerger Reading Thread' terminated due to an
> exception: Bug in input gate/channel logic: input gate gotnotified by
> channel about available data, but none was available.
>         at
> org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:471)
>         at
> org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:362)
>         at
> org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:205)
>         at java.lang.Thread.run(Thread.java:701)
> Caused by: java.lang.RuntimeException: Error obtaining the sorted
> input: Thread 'SortMerger Reading Thread' terminated due to an
> exception: Bug in input gate/channel logic: input gate gotnotified by
> channel about available data, but none was available.
>         at
> org.apache.flink.runtime.operators.sort.UnilateralSortMerger.getIterator(UnilateralSortMerger.java:607)
>         at
> org.apache.flink.runtime.operators.RegularPactTask.getInput(RegularPactTask.java:1131)
>         at
> org.apache.flink.runtime.operators.GroupReduceDriver.prepare(GroupReduceDriver.java:94)
>         at
> org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:466)
>         ... 3 more
> Caused by: java.io.IOException: Thread 'SortMerger Reading Thread'
> terminated due to an exception: Bug in input gate/channel logic: input
> gate gotnotified by channel about available data, but none was
> available.
>         at
> org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:784)
> Caused by: java.lang.IllegalStateException: Bug in input gate/channel
> logic: input gate gotnotified by channel about available data, but
> none was available.
>         at
> org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.getNextBufferOrEvent(SingleInputGate.java:314)
>         at
> org.apache.flink.runtime.io.network.partition.consumer.UnionInputGate.getNextBufferOrEvent(UnionInputGate.java:141)
>         at
> org.apache.flink.runtime.io.network.api.reader.AbstractRecordReader.getNextRecord(AbstractRecordReader.java:75)
>         at
> org.apache.flink.runtime.io.network.api.reader.MutableRecordReader.next(MutableRecordReader.java:34)
>         at
> org.apache.flink.runtime.operators.util.ReaderIterator.next(ReaderIterator.java:59)
>         at
> org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ReadingThread.go(UnilateralSortMerger.java:958)
>         at
> org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:781)
>
> 03/10/2015 13:44:10     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(10/16) switched to FAILED
> java.lang.Exception: The data preparation for task 'Reduce(SUM(1), at
> getDegrees(Graph.java:664)' , caused an error: Error obtaining the
> sorted input: Thread 'SortMerger Reading Thread' terminated due to an
> exception: Bug in input gate/channel logic: input gate gotnotified by
> channel about available data, but none was available.
>         at
> org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:471)
>         at
> org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:362)
>         at
> org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:205)
>         at java.lang.Thread.run(Thread.java:701)
> Caused by: java.lang.RuntimeException: Error obtaining the sorted
> input: Thread 'SortMerger Reading Thread' terminated due to an
> exception: Bug in input gate/channel logic: input gate gotnotified by
> channel about available data, but none was available.
>         at
> org.apache.flink.runtime.operators.sort.UnilateralSortMerger.getIterator(UnilateralSortMerger.java:607)
>         at
> org.apache.flink.runtime.operators.RegularPactTask.getInput(RegularPactTask.java:1131)
>         at
> org.apache.flink.runtime.operators.GroupReduceDriver.prepare(GroupReduceDriver.java:94)
>         at
> org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:466)
>         ... 3 more
> Caused by: java.io.IOException: Thread 'SortMerger Reading Thread'
> terminated due to an exception: Bug in input gate/channel logic: input
> gate gotnotified by channel about available data, but none was
> available.
>         at
> org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:784)
> Caused by: java.lang.IllegalStateException: Bug in input gate/channel
> logic: input gate gotnotified by channel about available data, but
> none was available.
>         at
> org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.getNextBufferOrEvent(SingleInputGate.java:314)
>         at
> org.apache.flink.runtime.io.network.partition.consumer.UnionInputGate.getNextBufferOrEvent(UnionInputGate.java:141)
>         at
> org.apache.flink.runtime.io.network.api.reader.AbstractRecordReader.getNextRecord(AbstractRecordReader.java:75)
>         at
> org.apache.flink.runtime.io.network.api.reader.MutableRecordReader.next(MutableRecordReader.java:34)
>         at
> org.apache.flink.runtime.operators.util.ReaderIterator.next(ReaderIterator.java:59)
>         at
> org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ReadingThread.go(UnilateralSortMerger.java:958)
>         at
> org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:781)
>
> 03/10/2015 13:44:10     Reduce(SUM(1), at getDegrees(Graph.java:664)(9/16)
> switched to FAILED
> java.lang.Exception: The data preparation for task 'Reduce(SUM(1), at
> getDegrees(Graph.java:664)' , caused an error: Error obtaining the
> sorted input: Thread 'SortMerger Reading Thread' terminated due to an
> exception: Bug in input gate/channel logic: input gate gotnotified by
> channel about available data, but none was available.
>         at
> org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:471)
>         at
> org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:362)
>         at
> org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:205)
>         at java.lang.Thread.run(Thread.java:701)
> Caused by: java.lang.RuntimeException: Error obtaining the sorted
> input: Thread 'SortMerger Reading Thread' terminated due to an
> exception: Bug in input gate/channel logic: input gate gotnotified by
> channel about available data, but none was available.
>         at
> org.apache.flink.runtime.operators.sort.UnilateralSortMerger.getIterator(UnilateralSortMerger.java:607)
>         at
> org.apache.flink.runtime.operators.RegularPactTask.getInput(RegularPactTask.java:1131)
>         at
> org.apache.flink.runtime.operators.GroupReduceDriver.prepare(GroupReduceDriver.java:94)
>         at
> org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:466)
>         ... 3 more
> Caused by: java.io.IOException: Thread 'SortMerger Reading Thread'
> terminated due to an exception: Bug in input gate/channel logic: input
> gate gotnotified by channel about available data, but none was
> available.
>         at
> org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:784)
> Caused by: java.lang.IllegalStateException: Bug in input gate/channel
> logic: input gate gotnotified by channel about available data, but
> none was available.
>         at
> org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.getNextBufferOrEvent(SingleInputGate.java:314)
>         at
> org.apache.flink.runtime.io.network.partition.consumer.UnionInputGate.getNextBufferOrEvent(UnionInputGate.java:141)
>         at
> org.apache.flink.runtime.io.network.api.reader.AbstractRecordReader.getNextRecord(AbstractRecordReader.java:75)
>         at
> org.apache.flink.runtime.io.network.api.reader.MutableRecordReader.next(MutableRecordReader.java:34)
>         at
> org.apache.flink.runtime.operators.util.ReaderIterator.next(ReaderIterator.java:59)
>         at
> org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ReadingThread.go(UnilateralSortMerger.java:958)
>         at
> org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:781)
>
> 03/10/2015 13:44:10     Reduce(SUM(1), at getDegrees(Graph.java:664)(8/16)
> switched to FAILED
> java.lang.Exception: The data preparation for task 'Reduce(SUM(1), at
> getDegrees(Graph.java:664)' , caused an error: Error obtaining the
> sorted input: Thread 'SortMerger Reading Thread' terminated due to an
> exception: Bug in input gate/channel logic: input gate gotnotified by
> channel about available data, but none was available.
>         at
> org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:471)
>         at
> org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:362)
>         at
> org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:205)
>         at java.lang.Thread.run(Thread.java:701)
> Caused by: java.lang.RuntimeException: Error obtaining the sorted
> input: Thread 'SortMerger Reading Thread' terminated due to an
> exception: Bug in input gate/channel logic: input gate gotnotified by
> channel about available data, but none was available.
>         at
> org.apache.flink.runtime.operators.sort.UnilateralSortMerger.getIterator(UnilateralSortMerger.java:607)
>         at
> org.apache.flink.runtime.operators.RegularPactTask.getInput(RegularPactTask.java:1131)
>         at
> org.apache.flink.runtime.operators.GroupReduceDriver.prepare(GroupReduceDriver.java:94)
>         at
> org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:466)
>         ... 3 more
> Caused by: java.io.IOException: Thread 'SortMerger Reading Thread'
> terminated due to an exception: Bug in input gate/channel logic: input
> gate gotnotified by channel about available data, but none was
> available.
>         at
> org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:784)
> Caused by: java.lang.IllegalStateException: Bug in input gate/channel
> logic: input gate gotnotified by channel about available data, but
> none was available.
>         at
> org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.getNextBufferOrEvent(SingleInputGate.java:314)
>         at
> org.apache.flink.runtime.io.network.partition.consumer.UnionInputGate.getNextBufferOrEvent(UnionInputGate.java:141)
>         at
> org.apache.flink.runtime.io.network.api.reader.AbstractRecordReader.getNextRecord(AbstractRecordReader.java:75)
>         at
> org.apache.flink.runtime.io.network.api.reader.MutableRecordReader.next(MutableRecordReader.java:34)
>         at
> org.apache.flink.runtime.operators.util.ReaderIterator.next(ReaderIterator.java:59)
>         at
> org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ReadingThread.go(UnilateralSortMerger.java:958)
>         at
> org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:781)
>
> 03/10/2015 13:44:10     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(13/16) switched to FAILED
> java.lang.Exception: The data preparation for task 'Reduce(SUM(1), at
> getDegrees(Graph.java:664)' , caused an error: Error obtaining the
> sorted input: Thread 'SortMerger Reading Thread' terminated due to an
> exception: Bug in input gate/channel logic: input gate gotnotified by
> channel about available data, but none was available.
>         at
> org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:471)
>         at
> org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:362)
>         at
> org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:205)
>         at java.lang.Thread.run(Thread.java:701)
> Caused by: java.lang.RuntimeException: Error obtaining the sorted
> input: Thread 'SortMerger Reading Thread' terminated due to an
> exception: Bug in input gate/channel logic: input gate gotnotified by
> channel about available data, but none was available.
>         at
> org.apache.flink.runtime.operators.sort.UnilateralSortMerger.getIterator(UnilateralSortMerger.java:607)
>         at
> org.apache.flink.runtime.operators.RegularPactTask.getInput(RegularPactTask.java:1131)
>         at
> org.apache.flink.runtime.operators.GroupReduceDriver.prepare(GroupReduceDriver.java:94)
>         at
> org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:466)
>         ... 3 more
> Caused by: java.io.IOException: Thread 'SortMerger Reading Thread'
> terminated due to an exception: Bug in input gate/channel logic: input
> gate gotnotified by channel about available data, but none was
> available.
>         at
> org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:784)
> Caused by: java.lang.IllegalStateException: Bug in input gate/channel
> logic: input gate gotnotified by channel about available data, but
> none was available.
>         at
> org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.getNextBufferOrEvent(SingleInputGate.java:314)
>         at
> org.apache.flink.runtime.io.network.partition.consumer.UnionInputGate.getNextBufferOrEvent(UnionInputGate.java:141)
>         at
> org.apache.flink.runtime.io.network.api.reader.AbstractRecordReader.getNextRecord(AbstractRecordReader.java:75)
>         at
> org.apache.flink.runtime.io.network.api.reader.MutableRecordReader.next(MutableRecordReader.java:34)
>         at
> org.apache.flink.runtime.operators.util.ReaderIterator.next(ReaderIterator.java:59)
>         at
> org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ReadingThread.go(UnilateralSortMerger.java:958)
>         at
> org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:781)
>
> 03/10/2015 13:44:10     Reduce(SUM(1), at getDegrees(Graph.java:664)(6/16)
> switched to CANCELED
> 03/10/2015 13:44:10     Reduce(SUM(1), at getDegrees(Graph.java:664)(5/16)
> switched to CANCELED
> 03/10/2015 13:44:10     Reduce(SUM(1), at getDegrees(Graph.java:664)(4/16)
> switched to CANCELED
> 03/10/2015 13:44:10     Reduce(SUM(1), at getDegrees(Graph.java:664)(3/16)
> switched to CANCELED
> 03/10/2015 13:44:10     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(14/16) switched to FAILED
> java.lang.Exception: The data preparation for task 'Reduce(SUM(1), at
> getDegrees(Graph.java:664)' , caused an error: Error obtaining the
> sorted input: Thread 'SortMerger Reading Thread' terminated due to an
> exception: Bug in input gate/channel logic: input gate gotnotified by
> channel about available data, but none was available.
>         at
> org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:471)
>         at
> org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:362)
>         at
> org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:205)
>         at java.lang.Thread.run(Thread.java:701)
> Caused by: java.lang.RuntimeException: Error obtaining the sorted
> input: Thread 'SortMerger Reading Thread' terminated due to an
> exception: Bug in input gate/channel logic: input gate gotnotified by
> channel about available data, but none was available.
>         at
> org.apache.flink.runtime.operators.sort.UnilateralSortMerger.getIterator(UnilateralSortMerger.java:607)
>         at
> org.apache.flink.runtime.operators.RegularPactTask.getInput(RegularPactTask.java:1131)
>         at
> org.apache.flink.runtime.operators.GroupReduceDriver.prepare(GroupReduceDriver.java:94)
>         at
> org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:466)
>         ... 3 more
> Caused by: java.io.IOException: Thread 'SortMerger Reading Thread'
> terminated due to an exception: Bug in input gate/channel logic: input
> gate gotnotified by channel about available data, but none was
> available.
>         at
> org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:784)
> Caused by: java.lang.IllegalStateException: Bug in input gate/channel
> logic: input gate gotnotified by channel about available data, but
> none was available.
>         at
> org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.getNextBufferOrEvent(SingleInputGate.java:314)
>         at
> org.apache.flink.runtime.io.network.partition.consumer.UnionInputGate.getNextBufferOrEvent(UnionInputGate.java:141)
>         at
> org.apache.flink.runtime.io.network.api.reader.AbstractRecordReader.getNextRecord(AbstractRecordReader.java:75)
>         at
> org.apache.flink.runtime.io.network.api.reader.MutableRecordReader.next(MutableRecordReader.java:34)
>         at
> org.apache.flink.runtime.operators.util.ReaderIterator.next(ReaderIterator.java:59)
>         at
> org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ReadingThread.go(UnilateralSortMerger.java:958)
>         at
> org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:781)
>
> 03/10/2015 13:44:10     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(15/16) switched to FAILED
> java.lang.Exception: The data preparation for task 'Reduce(SUM(1), at
> getDegrees(Graph.java:664)' , caused an error: Error obtaining the
> sorted input: Thread 'SortMerger Reading Thread' terminated due to an
> exception: Bug in input gate/channel logic: input gate gotnotified by
> channel about available data, but none was available.
>         at
> org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:471)
>         at
> org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:362)
>         at
> org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:205)
>         at java.lang.Thread.run(Thread.java:701)
> Caused by: java.lang.RuntimeException: Error obtaining the sorted
> input: Thread 'SortMerger Reading Thread' terminated due to an
> exception: Bug in input gate/channel logic: input gate gotnotified by
> channel about available data, but none was available.
>         at
> org.apache.flink.runtime.operators.sort.UnilateralSortMerger.getIterator(UnilateralSortMerger.java:607)
>         at
> org.apache.flink.runtime.operators.RegularPactTask.getInput(RegularPactTask.java:1131)
>         at
> org.apache.flink.runtime.operators.GroupReduceDriver.prepare(GroupReduceDriver.java:94)
>         at
> org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:466)
>         ... 3 more
> Caused by: java.io.IOException: Thread 'SortMerger Reading Thread'
> terminated due to an exception: Bug in input gate/channel logic: input
> gate gotnotified by channel about available data, but none was
> available.
>         at
> org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:784)
> Caused by: java.lang.IllegalStateException: Bug in input gate/channel
> logic: input gate gotnotified by channel about available data, but
> none was available.
>         at
> org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.getNextBufferOrEvent(SingleInputGate.java:314)
>         at
> org.apache.flink.runtime.io.network.partition.consumer.UnionInputGate.getNextBufferOrEvent(UnionInputGate.java:141)
>         at
> org.apache.flink.runtime.io.network.api.reader.AbstractRecordReader.getNextRecord(AbstractRecordReader.java:75)
>         at
> org.apache.flink.runtime.io.network.api.reader.MutableRecordReader.next(MutableRecordReader.java:34)
>         at
> org.apache.flink.runtime.operators.util.ReaderIterator.next(ReaderIterator.java:59)
>         at
> org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ReadingThread.go(UnilateralSortMerger.java:958)
>         at
> org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:781)
>
> 03/10/2015 13:44:10     Reduce(SUM(1), at getDegrees(Graph.java:664)(1/16)
> switched to CANCELED
> 03/10/2015 13:44:10     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(16/16) switched to FAILED
> java.lang.Exception: The data preparation for task 'Reduce(SUM(1), at
> getDegrees(Graph.java:664)' , caused an error: Error obtaining the
> sorted input: Thread 'SortMerger Reading Thread' terminated due to an
> exception: Bug in input gate/channel logic: input gate gotnotified by
> channel about available data, but none was available.
>         at
> org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:471)
>         at
> org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:362)
>         at
> org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:205)
>         at java.lang.Thread.run(Thread.java:701)
> Caused by: java.lang.RuntimeException: Error obtaining the sorted
> input: Thread 'SortMerger Reading Thread' terminated due to an
> exception: Bug in input gate/channel logic: input gate gotnotified by
> channel about available data, but none was available.
>         at
> org.apache.flink.runtime.operators.sort.UnilateralSortMerger.getIterator(UnilateralSortMerger.java:607)
>         at
> org.apache.flink.runtime.operators.RegularPactTask.getInput(RegularPactTask.java:1131)
>         at
> org.apache.flink.runtime.operators.GroupReduceDriver.prepare(GroupReduceDriver.java:94)
>         at
> org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:466)
>         ... 3 more
> Caused by: java.io.IOException: Thread 'SortMerger Reading Thread'
> terminated due to an exception: Bug in input gate/channel logic: input
> gate gotnotified by channel about available data, but none was
> available.
>         at
> org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:784)
> Caused by: java.lang.IllegalStateException: Bug in input gate/channel
> logic: input gate gotnotified by channel about available data, but
> none was available.
>         at
> org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.getNextBufferOrEvent(SingleInputGate.java:314)
>         at
> org.apache.flink.runtime.io.network.partition.consumer.UnionInputGate.getNextBufferOrEvent(UnionInputGate.java:141)
>         at
> org.apache.flink.runtime.io.network.api.reader.AbstractRecordReader.getNextRecord(AbstractRecordReader.java:75)
>         at
> org.apache.flink.runtime.io.network.api.reader.MutableRecordReader.next(MutableRecordReader.java:34)
>         at
> org.apache.flink.runtime.operators.util.ReaderIterator.next(ReaderIterator.java:59)
>         at
> org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ReadingThread.go(UnilateralSortMerger.java:958)
>         at
> org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:781)
>
> 03/10/2015 13:44:10     Reduce(SUM(1), at getDegrees(Graph.java:664)(2/16)
> switched to FAILED
> java.lang.Exception: The data preparation for task 'Reduce(SUM(1), at
> getDegrees(Graph.java:664)' , caused an error: Error obtaining the
> sorted input: Thread 'SortMerger Reading Thread' terminated due to an
> exception: Bug in input gate/channel logic: input gate gotnotified by
> channel about available data, but none was available.
>         at
> org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:471)
>         at
> org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:362)
>         at
> org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:205)
>         at java.lang.Thread.run(Thread.java:701)
> Caused by: java.lang.RuntimeException: Error obtaining the sorted
> input: Thread 'SortMerger Reading Thread' terminated due to an
> exception: Bug in input gate/channel logic: input gate gotnotified by
> channel about available data, but none was available.
>         at
> org.apache.flink.runtime.operators.sort.UnilateralSortMerger.getIterator(UnilateralSortMerger.java:607)
>         at
> org.apache.flink.runtime.operators.RegularPactTask.getInput(RegularPactTask.java:1131)
>         at
> org.apache.flink.runtime.operators.GroupReduceDriver.prepare(GroupReduceDriver.java:94)
>         at
> org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:466)
>         ... 3 more
> Caused by: java.io.IOException: Thread 'SortMerger Reading Thread'
> terminated due to an exception: Bug in input gate/channel logic: input
> gate gotnotified by channel about available data, but none was
> available.
>         at
> org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:784)
> Caused by: java.lang.IllegalStateException: Bug in input gate/channel
> logic: input gate gotnotified by channel about available data, but
> none was available.
>         at
> org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.getNextBufferOrEvent(SingleInputGate.java:314)
>         at
> org.apache.flink.runtime.io.network.partition.consumer.UnionInputGate.getNextBufferOrEvent(UnionInputGate.java:141)
>         at
> org.apache.flink.runtime.io.network.api.reader.AbstractRecordReader.getNextRecord(AbstractRecordReader.java:75)
>         at
> org.apache.flink.runtime.io.network.api.reader.MutableRecordReader.next(MutableRecordReader.java:34)
>         at
> org.apache.flink.runtime.operators.util.ReaderIterator.next(ReaderIterator.java:59)
>         at
> org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ReadingThread.go(UnilateralSortMerger.java:958)
>         at
> org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:781)
>
> 03/10/2015 13:44:10     Job execution switched to status FAILED.
> 03/10/2015 13:44:11     Job execution switched to status RUNNING.
> 03/10/2015 13:44:11     DataSource (at
> getLongLongEdgeInvalidSrcTrgData(TestGraphUtils.java:75)
> (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to
> SCHEDULED
> 03/10/2015 13:44:11     DataSource (at
> getLongLongEdgeInvalidSrcTrgData(TestGraphUtils.java:75)
> (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to
> DEPLOYING
> 03/10/2015 13:44:11     DataSource (at
> getLongLongVertexData(TestGraphUtils.java:37)
> (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to
> SCHEDULED
> 03/10/2015 13:44:11     DataSource (at
> getLongLongVertexData(TestGraphUtils.java:37)
> (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to
> DEPLOYING
> 03/10/2015 13:44:11     DataSource (at
> getLongLongEdgeInvalidSrcTrgData(TestGraphUtils.java:75)
> (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to
> RUNNING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(1/16) switched to SCHEDULED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(1/16) switched to DEPLOYING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(2/16) switched to SCHEDULED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(2/16) switched to DEPLOYING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(3/16) switched to SCHEDULED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(4/16) switched to SCHEDULED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(3/16) switched to DEPLOYING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(4/16) switched to DEPLOYING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(5/16) switched to SCHEDULED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(6/16) switched to SCHEDULED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(5/16) switched to DEPLOYING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(6/16) switched to DEPLOYING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(7/16) switched to SCHEDULED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(7/16) switched to DEPLOYING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(8/16) switched to SCHEDULED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(8/16) switched to DEPLOYING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(9/16) switched to SCHEDULED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(9/16) switched to DEPLOYING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(10/16) switched to SCHEDULED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(10/16) switched to DEPLOYING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(11/16) switched to SCHEDULED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(11/16) switched to DEPLOYING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(12/16) switched to SCHEDULED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(12/16) switched to DEPLOYING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(13/16) switched to SCHEDULED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(14/16) switched to SCHEDULED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(13/16) switched to DEPLOYING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(14/16) switched to DEPLOYING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(15/16) switched to SCHEDULED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(15/16) switched to DEPLOYING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(16/16) switched to SCHEDULED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(16/16) switched to DEPLOYING
> 03/10/2015 13:44:11     DataSource (at
> getLongLongVertexData(TestGraphUtils.java:37)
> (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to
> RUNNING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(1/16) switched to SCHEDULED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(1/16) switched to DEPLOYING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(2/16) switched to SCHEDULED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(2/16) switched to DEPLOYING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(1/16) switched to RUNNING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(3/16) switched to SCHEDULED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(3/16) switched to DEPLOYING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(4/16) switched to SCHEDULED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(4/16) switched to DEPLOYING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(5/16) switched to SCHEDULED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(5/16) switched to DEPLOYING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(6/16) switched to SCHEDULED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(6/16) switched to DEPLOYING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(7/16) switched to SCHEDULED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(7/16) switched to DEPLOYING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(8/16) switched to SCHEDULED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(8/16) switched to DEPLOYING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(9/16) switched to SCHEDULED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(9/16) switched to DEPLOYING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(10/16) switched to SCHEDULED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(10/16) switched to DEPLOYING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(11/16) switched to SCHEDULED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(11/16) switched to DEPLOYING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(12/16) switched to SCHEDULED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(13/16) switched to SCHEDULED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(12/16) switched to DEPLOYING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(13/16) switched to DEPLOYING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(14/16) switched to SCHEDULED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(14/16) switched to DEPLOYING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(15/16) switched to SCHEDULED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(15/16) switched to DEPLOYING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(16/16) switched to SCHEDULED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(16/16) switched to DEPLOYING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(2/16) switched to RUNNING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(3/16) switched to RUNNING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(4/16) switched to RUNNING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(5/16) switched to RUNNING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(7/16) switched to RUNNING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(8/16) switched to RUNNING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(9/16) switched to RUNNING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(10/16) switched to RUNNING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(6/16) switched to RUNNING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(11/16) switched to RUNNING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(12/16) switched to RUNNING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(13/16) switched to RUNNING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(1/16) switched to RUNNING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(2/16) switched to RUNNING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(3/16) switched to RUNNING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(4/16) switched to RUNNING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(5/16) switched to RUNNING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(6/16) switched to RUNNING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(8/16) switched to RUNNING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(9/16) switched to RUNNING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(10/16) switched to RUNNING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(11/16) switched to RUNNING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(12/16) switched to RUNNING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(13/16) switched to RUNNING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(14/16) switched to RUNNING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(15/16) switched to RUNNING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(16/16) switched to RUNNING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(14/16) switched to RUNNING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(7/16) switched to RUNNING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(16/16) switched to RUNNING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(15/16) switched to RUNNING
> 03/10/2015 13:44:11     DataSource (at
> getLongLongEdgeInvalidSrcTrgData(TestGraphUtils.java:75)
> (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to
> FINISHED
> 03/10/2015 13:44:11     Reduce(SUM(1), at getDegrees(Graph.java:664)(1/16)
> switched to SCHEDULED
> 03/10/2015 13:44:11     Reduce(SUM(1), at getDegrees(Graph.java:664)(1/16)
> switched to DEPLOYING
> 03/10/2015 13:44:11     Reduce(SUM(1), at getDegrees(Graph.java:664)(2/16)
> switched to SCHEDULED
> 03/10/2015 13:44:11     Reduce(SUM(1), at getDegrees(Graph.java:664)(2/16)
> switched to DEPLOYING
> 03/10/2015 13:44:11     Reduce(SUM(1), at getDegrees(Graph.java:664)(3/16)
> switched to SCHEDULED
> 03/10/2015 13:44:11     Reduce(SUM(1), at getDegrees(Graph.java:664)(3/16)
> switched to DEPLOYING
> 03/10/2015 13:44:11     Reduce(SUM(1), at getDegrees(Graph.java:664)(4/16)
> switched to SCHEDULED
> 03/10/2015 13:44:11     Reduce(SUM(1), at getDegrees(Graph.java:664)(4/16)
> switched to DEPLOYING
> 03/10/2015 13:44:11     Reduce(SUM(1), at getDegrees(Graph.java:664)(5/16)
> switched to SCHEDULED
> 03/10/2015 13:44:11     Reduce(SUM(1), at getDegrees(Graph.java:664)(5/16)
> switched to DEPLOYING
> 03/10/2015 13:44:11     Reduce(SUM(1), at getDegrees(Graph.java:664)(6/16)
> switched to SCHEDULED
> 03/10/2015 13:44:11     Reduce(SUM(1), at getDegrees(Graph.java:664)(6/16)
> switched to DEPLOYING
> 03/10/2015 13:44:11     Reduce(SUM(1), at getDegrees(Graph.java:664)(7/16)
> switched to SCHEDULED
> 03/10/2015 13:44:11     Reduce(SUM(1), at getDegrees(Graph.java:664)(7/16)
> switched to DEPLOYING
> 03/10/2015 13:44:11     Reduce(SUM(1), at getDegrees(Graph.java:664)(8/16)
> switched to SCHEDULED
> 03/10/2015 13:44:11     Reduce(SUM(1), at getDegrees(Graph.java:664)(8/16)
> switched to DEPLOYING
> 03/10/2015 13:44:11     Reduce(SUM(1), at getDegrees(Graph.java:664)(9/16)
> switched to SCHEDULED
> 03/10/2015 13:44:11     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(10/16) switched to SCHEDULED
> 03/10/2015 13:44:11     Reduce(SUM(1), at getDegrees(Graph.java:664)(9/16)
> switched to DEPLOYING
> 03/10/2015 13:44:11     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(10/16) switched to DEPLOYING
> 03/10/2015 13:44:11     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(11/16) switched to SCHEDULED
> 03/10/2015 13:44:11     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(12/16) switched to SCHEDULED
> 03/10/2015 13:44:11     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(11/16) switched to DEPLOYING
> 03/10/2015 13:44:11     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(12/16) switched to DEPLOYING
> 03/10/2015 13:44:11     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(13/16) switched to SCHEDULED
> 03/10/2015 13:44:11     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(14/16) switched to SCHEDULED
> 03/10/2015 13:44:11     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(13/16) switched to DEPLOYING
> 03/10/2015 13:44:11     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(14/16) switched to DEPLOYING
> 03/10/2015 13:44:11     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(15/16) switched to SCHEDULED
> 03/10/2015 13:44:11     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(16/16) switched to SCHEDULED
> 03/10/2015 13:44:11     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(15/16) switched to DEPLOYING
> 03/10/2015 13:44:11     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(16/16) switched to DEPLOYING
> 03/10/2015 13:44:11     DataSource (at
> getLongLongVertexData(TestGraphUtils.java:37)
> (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to
> FINISHED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(4/16) switched to FINISHED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(6/16) switched to FINISHED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(9/16) switched to FINISHED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(11/16) switched to FINISHED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(16/16) switched to FINISHED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(14/16) switched to FINISHED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(2/16) switched to FINISHED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(14/16) switched to FINISHED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(12/16) switched to FINISHED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(10/16) switched to FINISHED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(1/16) switched to FINISHED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(5/16) switched to FINISHED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(3/16) switched to FINISHED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(7/16) switched to FINISHED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(8/16) switched to FINISHED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(16/16) switched to FINISHED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(1/16) switched to FAILED
> java.util.NoSuchElementException: The edge src/trg id could not be
> found within the vertexIds
>         at
> org.apache.flink.graph.Graph$CountNeighborsCoGroup.coGroup(Graph.java:643)
>         at
> org.apache.flink.runtime.operators.CoGroupDriver.run(CoGroupDriver.java:152)
>         at
> org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:496)
>         at
> org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:362)
>         at
> org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:205)
>         at java.lang.Thread.run(Thread.java:701)
>
> 03/10/2015 13:44:11     Job execution switched to status FAILING.
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(2/16) switched to CANCELING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(3/16) switched to CANCELING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(4/16) switched to CANCELING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(5/16) switched to CANCELING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(6/16) switched to CANCELING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(7/16) switched to CANCELING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(8/16) switched to CANCELING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(9/16) switched to CANCELING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(10/16) switched to CANCELING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(11/16) switched to CANCELING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(12/16) switched to CANCELING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(13/16) switched to CANCELING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(15/16) switched to CANCELING
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(15/16) switched to CANCELING
> 03/10/2015 13:44:11     Reduce(SUM(1), at getDegrees(Graph.java:664)(1/16)
> switched to CANCELING
> 03/10/2015 13:44:11     Reduce(SUM(1), at getDegrees(Graph.java:664)(2/16)
> switched to CANCELING
> 03/10/2015 13:44:11     Reduce(SUM(1), at getDegrees(Graph.java:664)(3/16)
> switched to CANCELING
> 03/10/2015 13:44:11     Reduce(SUM(1), at getDegrees(Graph.java:664)(4/16)
> switched to CANCELING
> 03/10/2015 13:44:11     Reduce(SUM(1), at getDegrees(Graph.java:664)(5/16)
> switched to CANCELING
> 03/10/2015 13:44:11     Reduce(SUM(1), at getDegrees(Graph.java:664)(6/16)
> switched to CANCELING
> 03/10/2015 13:44:11     Reduce(SUM(1), at getDegrees(Graph.java:664)(7/16)
> switched to CANCELING
> 03/10/2015 13:44:11     Reduce(SUM(1), at getDegrees(Graph.java:664)(8/16)
> switched to CANCELING
> 03/10/2015 13:44:11     Reduce(SUM(1), at getDegrees(Graph.java:664)(9/16)
> switched to CANCELING
> 03/10/2015 13:44:11     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(10/16) switched to CANCELING
> 03/10/2015 13:44:11     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(11/16) switched to CANCELING
> 03/10/2015 13:44:11     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(12/16) switched to CANCELING
> 03/10/2015 13:44:11     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(13/16) switched to CANCELING
> 03/10/2015 13:44:11     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(14/16) switched to CANCELING
> 03/10/2015 13:44:11     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(15/16) switched to CANCELING
> 03/10/2015 13:44:11     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(16/16) switched to CANCELING
> 03/10/2015 13:44:11
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@141689ca
> )(1/16)
> switched to CANCELED
> 03/10/2015 13:44:11
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@141689ca
> )(2/16)
> switched to CANCELED
> 03/10/2015 13:44:11
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@141689ca
> )(3/16)
> switched to CANCELED
> 03/10/2015 13:44:11
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@141689ca
> )(4/16)
> switched to CANCELED
> 03/10/2015 13:44:11
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@141689ca
> )(5/16)
> switched to CANCELED
> 03/10/2015 13:44:11
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@141689ca
> )(6/16)
> switched to CANCELED
> 03/10/2015 13:44:11
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@141689ca
> )(7/16)
> switched to CANCELED
> 03/10/2015 13:44:11
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@141689ca
> )(8/16)
> switched to CANCELED
> 03/10/2015 13:44:11
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@141689ca
> )(9/16)
> switched to CANCELED
> 03/10/2015 13:44:11
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@141689ca
> )(10/16)
> switched to CANCELED
> 03/10/2015 13:44:11
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@141689ca
> )(11/16)
> switched to CANCELED
> 03/10/2015 13:44:11
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@141689ca
> )(12/16)
> switched to CANCELED
> 03/10/2015 13:44:11
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@141689ca
> )(13/16)
> switched to CANCELED
> 03/10/2015 13:44:11
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@141689ca
> )(14/16)
> switched to CANCELED
> 03/10/2015 13:44:11
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@141689ca
> )(15/16)
> switched to CANCELED
> 03/10/2015 13:44:11
>  DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@141689ca
> )(16/16)
> switched to CANCELED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(13/16) switched to FAILED
> java.util.NoSuchElementException: The edge src/trg id could not be
> found within the vertexIds
>         at
> org.apache.flink.graph.Graph$CountNeighborsCoGroup.coGroup(Graph.java:643)
>         at
> org.apache.flink.runtime.operators.CoGroupDriver.run(CoGroupDriver.java:152)
>         at
> org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:496)
>         at
> org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:362)
>         at
> org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:205)
>         at java.lang.Thread.run(Thread.java:701)
>
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(2/16) switched to CANCELED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(3/16) switched to CANCELED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(4/16) switched to CANCELED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(5/16) switched to CANCELED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(8/16) switched to CANCELED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(7/16) switched to CANCELED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(6/16) switched to CANCELED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(9/16) switched to FAILED
> java.util.NoSuchElementException: The edge src/trg id could not be
> found within the vertexIds
>         at
> org.apache.flink.graph.Graph$CountNeighborsCoGroup.coGroup(Graph.java:643)
>         at
> org.apache.flink.runtime.operators.CoGroupDriver.run(CoGroupDriver.java:152)
>         at
> org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:496)
>         at
> org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:362)
>         at
> org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:205)
>         at java.lang.Thread.run(Thread.java:701)
>
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(10/16) switched to CANCELED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(13/16) switched to CANCELED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(12/16) switched to CANCELED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(11/16) switched to CANCELED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> outDegrees(Graph.java:625))(15/16) switched to CANCELED
> 03/10/2015 13:44:11     CoGroup (CoGroup at
> inDegrees(Graph.java:655))(15/16) switched to CANCELED
> 03/10/2015 13:44:11     Reduce(SUM(1), at getDegrees(Graph.java:664)(7/16)
> switched to CANCELED
> 03/10/2015 13:44:11     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(16/16) switched to CANCELED
> 03/10/2015 13:44:11     Reduce(SUM(1), at getDegrees(Graph.java:664)(3/16)
> switched to CANCELED
> 03/10/2015 13:44:11     Reduce(SUM(1), at getDegrees(Graph.java:664)(2/16)
> switched to CANCELED
> 03/10/2015 13:44:11     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(14/16) switched to CANCELED
> 03/10/2015 13:44:11     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(13/16) switched to CANCELED
> 03/10/2015 13:44:11     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(12/16) switched to CANCELED
> 03/10/2015 13:44:11     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(11/16) switched to CANCELED
> 03/10/2015 13:44:11     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(10/16) switched to CANCELED
> 03/10/2015 13:44:11     Reduce(SUM(1), at getDegrees(Graph.java:664)(9/16)
> switched to CANCELED
> 03/10/2015 13:44:11     Reduce(SUM(1), at getDegrees(Graph.java:664)(6/16)
> switched to CANCELED
> 03/10/2015 13:44:11     Reduce(SUM(1), at getDegrees(Graph.java:664)(5/16)
> switched to CANCELED
> 03/10/2015 13:44:11     Reduce(SUM(1), at getDegrees(Graph.java:664)(4/16)
> switched to CANCELED
> 03/10/2015 13:44:11     Reduce(SUM(1), at getDegrees(Graph.java:664)(8/16)
> switched to FAILED
> java.lang.Exception: The data preparation for task 'Reduce(SUM(1), at
> getDegrees(Graph.java:664)' , caused an error: Error obtaining the
> sorted input: Thread 'SortMerger Reading Thread' terminated due to an
> exception: Intermediate result partition has already been released.
>         at
> org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:471)
>         at
> org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:362)
>         at
> org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:205)
>         at java.lang.Thread.run(Thread.java:701)
> Caused by: java.lang.RuntimeException: Error obtaining the sorted
> input: Thread 'SortMerger Reading Thread' terminated due to an
> exception: Intermediate result partition has already been released.
>         at
> org.apache.flink.runtime.operators.sort.UnilateralSortMerger.getIterator(UnilateralSortMerger.java:607)
>         at
> org.apache.flink.runtime.operators.RegularPactTask.getInput(RegularPactTask.java:1131)
>         at
> org.apache.flink.runtime.operators.GroupReduceDriver.prepare(GroupReduceDriver.java:94)
>         at
> org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:466)
>         ... 3 more
> Caused by: java.io.IOException: Thread 'SortMerger Reading Thread'
> terminated due to an exception: Intermediate result partition has
> already been released.
>         at
> org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:784)
> Caused by:
> org.apache.flink.runtime.io.network.partition.queue.IllegalQueueIteratorRequestException:
> Intermediate result partition has already been released.
>         at
> org.apache.flink.runtime.io.network.partition.IntermediateResultPartition.getQueueIterator(IntermediateResultPartition.java:222)
>         at
> org.apache.flink.runtime.io.network.partition.IntermediateResultPartitionManager.getIntermediateResultPartitionIterator(IntermediateResultPartitionManager.java:136)
>         at
> org.apache.flink.runtime.io.network.partition.consumer.LocalInputChannel.requestIntermediateResultPartition(LocalInputChannel.java:78)
>         at
> org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.requestPartitions(SingleInputGate.java:287)
>         at
> org.apache.flink.runtime.io.network.partition.consumer.UnionInputGate.requestPartitions(UnionInputGate.java:126)
>         at
> org.apache.flink.runtime.io.network.partition.consumer.UnionInputGate.getNextBufferOrEvent(UnionInputGate.java:137)
>         at
> org.apache.flink.runtime.io.network.api.reader.AbstractRecordReader.getNextRecord(AbstractRecordReader.java:75)
>         at
> org.apache.flink.runtime.io.network.api.reader.MutableRecordReader.next(MutableRecordReader.java:34)
>         at
> org.apache.flink.runtime.operators.util.ReaderIterator.next(ReaderIterator.java:59)
>         at
> org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ReadingThread.go(UnilateralSortMerger.java:958)
>         at
> org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:781)
>
> 03/10/2015 13:44:11     Reduce(SUM(1), at getDegrees(Graph.java:664)(1/16)
> switched to FAILED
> java.lang.Exception: The data preparation for task 'Reduce(SUM(1), at
> getDegrees(Graph.java:664)' , caused an error: Error obtaining the
> sorted input: Thread 'SortMerger Reading Thread' terminated due to an
> exception: Bug in input gate/channel logic: input gate gotnotified by
> channel about available data, but none was available.
>         at
> org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:471)
>         at
> org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:362)
>         at
> org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:205)
>         at java.lang.Thread.run(Thread.java:701)
> Caused by: java.lang.RuntimeException: Error obtaining the sorted
> input: Thread 'SortMerger Reading Thread' terminated due to an
> exception: Bug in input gate/channel logic: input gate gotnotified by
> channel about available data, but none was available.
>         at
> org.apache.flink.runtime.operators.sort.UnilateralSortMerger.getIterator(UnilateralSortMerger.java:607)
>         at
> org.apache.flink.runtime.operators.RegularPactTask.getInput(RegularPactTask.java:1131)
>         at
> org.apache.flink.runtime.operators.GroupReduceDriver.prepare(GroupReduceDriver.java:94)
>         at
> org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:466)
>         ... 3 more
> Caused by: java.io.IOException: Thread 'SortMerger Reading Thread'
> terminated due to an exception: Bug in input gate/channel logic: input
> gate gotnotified by channel about available data, but none was
> available.
>         at
> org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:784)
> Caused by: java.lang.IllegalStateException: Bug in input gate/channel
> logic: input gate gotnotified by channel about available data, but
> none was available.
>         at
> org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.getNextBufferOrEvent(SingleInputGate.java:314)
>         at
> org.apache.flink.runtime.io.network.partition.consumer.UnionInputGate.getNextBufferOrEvent(UnionInputGate.java:141)
>         at
> org.apache.flink.runtime.io.network.api.reader.AbstractRecordReader.getNextRecord(AbstractRecordReader.java:75)
>         at
> org.apache.flink.runtime.io.network.api.reader.MutableRecordReader.next(MutableRecordReader.java:34)
>         at
> org.apache.flink.runtime.operators.util.ReaderIterator.next(ReaderIterator.java:59)
>         at
> org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ReadingThread.go(UnilateralSortMerger.java:958)
>         at
> org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:781)
>
> 03/10/2015 13:44:11     Reduce(SUM(1), at
> getDegrees(Graph.java:664)(15/16) switched to CANCELED
> 03/10/2015 13:44:11     Job execution switched to status FAILED.
> Tests run: 5, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 10.799
> sec - in org.apache.flink.graph.test.DegreesWithExceptionITCase
> Running org.apache.flink.graph.test.VertexCentricConnectedComponentsITCase
> Tests run: 8, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 11.046
> sec - in org.apache.flink.graph.test.WeaklyConnectedITCase
> Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 6.749
> sec - in org.apache.flink.graph.test.VertexCentricConnectedComponentsITCase
>
> Results :
>
> Tests run: 180, Failures: 0, Errors: 0, Skipped: 0
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message