Great, thanks Andra!
On Mar 10, 2015 5:52 PM, "Andra Lungu" <lungu.an...@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.an...@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 <
> > vasilikikala...@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 <se...@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.an...@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 <se...@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 <
> >> > > > vasilikikala...@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 <se...@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
> >> > > > > > outDegree...
