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 17:11:44 GMT
For an example, see here:
flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/AggregateITCase.java

I also just realized we have this class, very useful...

On Tue, Mar 10, 2015 at 6:10 PM, Stephan Ewen <sewen@apache.org> wrote:

> I just saw, you can also simply use the MultipleProgramsTestBase.
>
> It starts the cluster for you. Then you can actually stick to using
> "ExecutionEnvironment.getExecutionEnvironment()", because the TestBase sets
> the context environment
> to its internal testing cluster.
>
> On Tue, Mar 10, 2015 at 5:49 PM, Andra Lungu <lungu.andra@gmail.com>
> wrote:
>
>> Fixed. My bad. I had a trailing local job manager still running.
>>
>> On Tue, Mar 10, 2015 at 5:36 PM, Andra Lungu <lungu.andra@gmail.com>
>> wrote:
>>
>> > So the sysout suppression worked like a charm. Thanks!
>> >
>> > However, this mini cluster setup is giving me a bit of a rough time.
>> > I added this to the test suite:
>> >
>> > @BeforeClass
>> > public static void setupCluster() {
>> >    Configuration config = new Configuration();
>> >
>> config.setInteger(ConfigConstants.LOCAL_INSTANCE_MANAGER_NUMBER_TASK_MANAGER,
>> 2);
>> >    config.setInteger(ConfigConstants.TASK_MANAGER_NUM_TASK_SLOTS, 2);
>> >    config.setString(ConfigConstants.AKKA_WATCH_HEARTBEAT_PAUSE, "2 s");
>> >
>> >    cluster = new ForkableFlinkMiniCluster(config, false);
>> > }
>> >
>> > And then I got:
>> > org.jboss.netty.channel.ChannelException: Failed to bind to: /
>> > 127.0.0.1:6123
>> >
>> > because the address was already in use.
>> >
>> > Also, do I have to use something like this
>> > ExecutionEnvironment.createRemoteEnvironment(
>> >                         "localhost", cluster.getJobManagerRPCPort());
>> > instead of getExecutionEnvironment()?
>> >
>> > I get the same error in both cases.
>> >
>> > Thank you!
>> > Andra
>> >
>> > On Tue, Mar 10, 2015 at 5:30 PM, Vasiliki Kalavri <
>> > vasilikikalavri@gmail.com> wrote:
>> >
>> >> I think all other gelly tests extend MultipleProgramsTestBase, which is
>> >> already using the mini-cluster set up :-)
>> >>
>> >>
>> >> On 10 March 2015 at 17:21, Stephan Ewen <sewen@apache.org> wrote:
>> >>
>> >> > I would suggest to do this for all tests that have more than one
>> >> > "ExectionEnvironment.getExecutionEnvironment()" call.
>> >> > Does not have to be at once, can be migrated bit by bit.
>> >> > Maybe whenever a test is touched anyways, it can be adjusted.
>> >> >
>> >> > This should speed up tests and it has the added benefit for the
>> system
>> >> as a
>> >> > whole to add more tests where multiple programs run on the same
>> cluster.
>> >> > That way we test for cluster stability, leaks, whether the system
>> >> cleans up
>> >> > properly after finished program executions.
>> >> >
>> >> >
>> >> > On Tue, Mar 10, 2015 at 4:32 PM, Andra Lungu <lungu.andra@gmail.com>
>> >> > wrote:
>> >> >
>> >> > > Hello Stephan,
>> >> > >
>> >> > > Would you like the mini-cluster set up for all the Gelly tests? Or
>> >> just
>> >> > for
>> >> > > the one dumping its output?
>> >> > >
>> >> > > Andra
>> >> > >
>> >> > > On Tue, Mar 10, 2015 at 3:22 PM, Stephan Ewen <sewen@apache.org>
>> >> wrote:
>> >> > >
>> >> > > > 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