[gelly] Tests fail, but build succeeds

[Stephan Ewen]

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