flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Stephan Ewen <se...@apache.org>
Subject Re: [gelly] Tests fail, but build succeeds
Date Tue, 10 Mar 2015 14:22:56 GMT
Ah, I see.

One thing to definitely fix in the near future is the followup exceptions
from cancelling. They should not swamp the log like this.

If you want to suppress systout printing, have a look here, we redirect
sysout and syserr for this reason in some tests (
flink-clients/src/test/java/org/apache/flink/client/program/ExecutionPlanAfterExecutionTest.java)

You can also significantly speed up your tests by reusing one mini cluster
across multiple tests. They way you do it right now spawns a local executor
for each test (bringing up actor systems, memory, etc)
By starting one in a "BeforeClass" method, you can use the same Flink
instance across multiple tests, making each individual test go like
zooooooooooom.

Have a look here for an example:
flink-tests/src/test/java/org/apache/flink/test/recovery/SimpleRecoveryITCase.java

It is even faster if you start it like this:

public static void setupCluster() {
    Configuration config = new Configuration();
  config.setInteger(ConfigConstants.TASK_MANAGER_NUM_TASK_SLOTS,
PARALLELISM);
  cluster = new ForkableFlinkMiniCluster(config);
}

Cheers,
Stephan



On Tue, Mar 10, 2015 at 3:05 PM, Vasiliki Kalavri <vasilikikalavri@gmail.com
> wrote:

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

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