Return-Path: X-Original-To: apmail-flink-dev-archive@www.apache.org Delivered-To: apmail-flink-dev-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 8F3F417C73 for ; Tue, 10 Mar 2015 14:05:52 +0000 (UTC) Received: (qmail 55438 invoked by uid 500); 10 Mar 2015 14:05:52 -0000 Delivered-To: apmail-flink-dev-archive@flink.apache.org Received: (qmail 55348 invoked by uid 500); 10 Mar 2015 14:05:52 -0000 Mailing-List: contact dev-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@flink.apache.org Delivered-To: mailing list dev@flink.apache.org Received: (qmail 55334 invoked by uid 99); 10 Mar 2015 14:05:52 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 10 Mar 2015 14:05:52 +0000 X-ASF-Spam-Status: No, hits=1.5 required=5.0 tests=HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: domain of vasilikikalavri@gmail.com designates 209.85.215.45 as permitted sender) Received: from [209.85.215.45] (HELO mail-la0-f45.google.com) (209.85.215.45) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 10 Mar 2015 14:05:31 +0000 Received: by labgq15 with SMTP id gq15so1954007lab.1 for ; Tue, 10 Mar 2015 07:05:09 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:in-reply-to:references:date:message-id:subject:from:to :content-type; bh=LxAH/PV4jWpvQZOXN71lMg2XbHRbo+PlK7DJVOa/vTo=; b=sBMydNd+1j9PXnuMFPvDHLhNztj4Oq7TNg1aMwwU0RXvCrVBiPwT5Wxm5dFY2Wg3Jr 6pKIcffj5wz6z79y6l4QiJQuMFj/mxyixzv2G1QvT2wA436Vp5cIQydAIJ+yZFljZ4qi 2eY/P3CAmJKoi9p54y8IbKbHMoNgqaORm+JzyCOVRgov3ZjacFHXZUOCVuTklRgAL/Zz yX1g2C5QhPS5Bp/M44HBLfjAHtT3M579uN7D0/XjNkEMgBws2KYEQy7UYPztna7iFJjl +llWzkbuotlKuN9Al+vuMcJ4rXwfrbMNwME5FVKAaNQI6UwNDL54JniiOPjUygUrVYMi GIJQ== MIME-Version: 1.0 X-Received: by 10.112.11.136 with SMTP id q8mr29915093lbb.30.1425996309639; Tue, 10 Mar 2015 07:05:09 -0700 (PDT) Received: by 10.114.242.98 with HTTP; Tue, 10 Mar 2015 07:05:09 -0700 (PDT) In-Reply-To: References: Date: Tue, 10 Mar 2015 15:05:09 +0100 Message-ID: Subject: Re: [gelly] Tests fail, but build succeeds From: Vasiliki Kalavri To: dev@flink.apache.org Content-Type: multipart/alternative; boundary=001a11c3b61e7cb7450510efa30f X-Virus-Checked: Checked by ClamAV on apache.org --001a11c3b61e7cb7450510efa30f Content-Type: text/plain; charset=UTF-8 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 wrote: > It seems JobExecution failures are not recognized in some of the Gelly > tests. > > Also, the tests are logging quite a bit, would be nice to make them a bit > more quiet. > How is the logging is created, btw. The log4j-tests.properties have the log > level set to OFF afaik. > > Here is a log from my latest build: > > Running org.apache.flink.graph.test.operations.FromCollectionITCase > > Running org.apache.flink.graph.test.operations.JoinWithVerticesITCase > Tests run: 6, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 3.844 > sec - in org.apache.flink.graph.test.operations.FromCollectionITCase > Running org.apache.flink.graph.test.operations.GraphCreationITCase > Tests run: 10, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 6.254 > sec - in org.apache.flink.graph.test.operations.JoinWithVerticesITCase > Running > org.apache.flink.graph.test.operations.ReduceOnNeighborMethodsITCase > Tests run: 10, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 5.622 > sec - in org.apache.flink.graph.test.operations.GraphCreationITCase > Running org.apache.flink.graph.test.operations.GraphMutationsITCase > Tests run: 12, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 5.631 > sec - in > org.apache.flink.graph.test.operations.ReduceOnNeighborMethodsITCase > Running > org.apache.flink.graph.test.operations.GraphCreationWithMapperITCase > Tests run: 18, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 3.827 > sec - in org.apache.flink.graph.test.operations.GraphMutationsITCase > Running org.apache.flink.graph.test.operations.GraphOperationsITCase > Tests run: 8, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 5.177 > sec - in > org.apache.flink.graph.test.operations.GraphCreationWithMapperITCase > Running org.apache.flink.graph.test.operations.MapVerticesITCase > Tests run: 20, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 4.299 > sec - in org.apache.flink.graph.test.operations.GraphOperationsITCase > Running org.apache.flink.graph.test.operations.ReduceOnEdgesMethodsITCase > Tests run: 10, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 3.916 > sec - in org.apache.flink.graph.test.operations.MapVerticesITCase > Running org.apache.flink.graph.test.operations.JoinWithEdgesITCase > Tests run: 12, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 6.375 > sec - in org.apache.flink.graph.test.operations.ReduceOnEdgesMethodsITCase > Running org.apache.flink.graph.test.operations.MapEdgesITCase > Tests run: 10, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 3.238 > sec - in org.apache.flink.graph.test.operations.MapEdgesITCase > Running org.apache.flink.graph.test.operations.DegreesITCase > Tests run: 30, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 9.136 > sec - in org.apache.flink.graph.test.operations.JoinWithEdgesITCase > Running org.apache.flink.graph.test.example.SingleSourceShortestPathsITCase > Tests run: 12, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 6.08 > sec - in org.apache.flink.graph.test.operations.DegreesITCase > Running org.apache.flink.graph.test.example.LabelPropagationExampleITCase > Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 4.102 > sec - in > org.apache.flink.graph.test.example.SingleSourceShortestPathsITCase > Running org.apache.flink.graph.test.DegreesWithExceptionITCase > 03/10/2015 13:44:04 Job execution switched to status RUNNING. > 03/10/2015 13:44:04 DataSource (at > getLongLongVertexData(TestGraphUtils.java:37) > (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to > SCHEDULED > 03/10/2015 13:44:04 DataSource (at > getLongLongVertexData(TestGraphUtils.java:37) > (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to > DEPLOYING > 03/10/2015 13:44:04 DataSource (at > getLongLongEdgeInvalidSrcData(TestGraphUtils.java:53) > (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to > SCHEDULED > 03/10/2015 13:44:04 DataSource (at > getLongLongEdgeInvalidSrcData(TestGraphUtils.java:53) > (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to > DEPLOYING > 03/10/2015 13:44:04 DataSource (at > getLongLongVertexData(TestGraphUtils.java:37) > (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to > RUNNING > 03/10/2015 13:44:04 DataSource (at > getLongLongEdgeInvalidSrcData(TestGraphUtils.java:53) > (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to > RUNNING > 03/10/2015 13:44:04 CoGroup (CoGroup at > outDegrees(Graph.java:625))(2/16) switched to SCHEDULED > 03/10/2015 13:44:04 CoGroup (CoGroup at > outDegrees(Graph.java:625))(3/16) switched to SCHEDULED > 03/10/2015 13:44:04 CoGroup (CoGroup at > outDegrees(Graph.java:625))(2/16) switched to DEPLOYING > 03/10/2015 13:44:04 CoGroup (CoGroup at > outDegrees(Graph.java:625))(3/16) switched to DEPLOYING > 03/10/2015 13:44:04 CoGroup (CoGroup at > outDegrees(Graph.java:625))(4/16) switched to SCHEDULED > 03/10/2015 13:44:04 CoGroup (CoGroup at > outDegrees(Graph.java:625))(4/16) switched to DEPLOYING > 03/10/2015 13:44:04 CoGroup (CoGroup at > outDegrees(Graph.java:625))(5/16) switched to SCHEDULED > 03/10/2015 13:44:04 CoGroup (CoGroup at > outDegrees(Graph.java:625))(5/16) switched to DEPLOYING > 03/10/2015 13:44:04 CoGroup (CoGroup at > outDegrees(Graph.java:625))(6/16) switched to SCHEDULED > 03/10/2015 13:44:04 CoGroup (CoGroup at > outDegrees(Graph.java:625))(6/16) switched to DEPLOYING > 03/10/2015 13:44:04 CoGroup (CoGroup at > outDegrees(Graph.java:625))(7/16) switched to SCHEDULED > 03/10/2015 13:44:04 CoGroup (CoGroup at > outDegrees(Graph.java:625))(7/16) switched to DEPLOYING > 03/10/2015 13:44:04 CoGroup (CoGroup at > outDegrees(Graph.java:625))(8/16) switched to SCHEDULED > 03/10/2015 13:44:04 CoGroup (CoGroup at > outDegrees(Graph.java:625))(8/16) switched to DEPLOYING > 03/10/2015 13:44:04 CoGroup (CoGroup at > outDegrees(Graph.java:625))(9/16) switched to SCHEDULED > 03/10/2015 13:44:04 CoGroup (CoGroup at > outDegrees(Graph.java:625))(9/16) switched to DEPLOYING > 03/10/2015 13:44:04 CoGroup (CoGroup at > outDegrees(Graph.java:625))(10/16) switched to SCHEDULED > 03/10/2015 13:44:04 CoGroup (CoGroup at > outDegrees(Graph.java:625))(10/16) switched to DEPLOYING > 03/10/2015 13:44:04 CoGroup (CoGroup at > outDegrees(Graph.java:625))(11/16) switched to SCHEDULED > 03/10/2015 13:44:04 CoGroup (CoGroup at > outDegrees(Graph.java:625))(11/16) switched to DEPLOYING > 03/10/2015 13:44:04 CoGroup (CoGroup at > outDegrees(Graph.java:625))(12/16) switched to SCHEDULED > 03/10/2015 13:44:04 CoGroup (CoGroup at > outDegrees(Graph.java:625))(12/16) switched to DEPLOYING > 03/10/2015 13:44:04 CoGroup (CoGroup at > outDegrees(Graph.java:625))(1/16) switched to SCHEDULED > 03/10/2015 13:44:04 CoGroup (CoGroup at > outDegrees(Graph.java:625))(1/16) switched to DEPLOYING > 03/10/2015 13:44:04 CoGroup (CoGroup at > outDegrees(Graph.java:625))(13/16) switched to SCHEDULED > 03/10/2015 13:44:04 CoGroup (CoGroup at > outDegrees(Graph.java:625))(13/16) switched to DEPLOYING > 03/10/2015 13:44:04 CoGroup (CoGroup at > outDegrees(Graph.java:625))(14/16) switched to SCHEDULED > 03/10/2015 13:44:04 CoGroup (CoGroup at > outDegrees(Graph.java:625))(14/16) switched to DEPLOYING > 03/10/2015 13:44:04 CoGroup (CoGroup at > outDegrees(Graph.java:625))(15/16) switched to SCHEDULED > 03/10/2015 13:44:04 CoGroup (CoGroup at > outDegrees(Graph.java:625))(15/16) switched to DEPLOYING > 03/10/2015 13:44:04 CoGroup (CoGroup at > outDegrees(Graph.java:625))(16/16) switched to SCHEDULED > 03/10/2015 13:44:04 CoGroup (CoGroup at > outDegrees(Graph.java:625))(16/16) switched to DEPLOYING > 03/10/2015 13:44:04 CoGroup (CoGroup at > outDegrees(Graph.java:625))(2/16) switched to RUNNING > 03/10/2015 13:44:04 CoGroup (CoGroup at > outDegrees(Graph.java:625))(6/16) switched to RUNNING > 03/10/2015 13:44:04 CoGroup (CoGroup at > outDegrees(Graph.java:625))(4/16) switched to RUNNING > 03/10/2015 13:44:04 CoGroup (CoGroup at > outDegrees(Graph.java:625))(3/16) switched to RUNNING > 03/10/2015 13:44:04 CoGroup (CoGroup at > outDegrees(Graph.java:625))(5/16) switched to RUNNING > 03/10/2015 13:44:04 CoGroup (CoGroup at > outDegrees(Graph.java:625))(7/16) switched to RUNNING > 03/10/2015 13:44:04 CoGroup (CoGroup at > outDegrees(Graph.java:625))(16/16) switched to RUNNING > 03/10/2015 13:44:04 CoGroup (CoGroup at > outDegrees(Graph.java:625))(15/16) switched to RUNNING > 03/10/2015 13:44:04 CoGroup (CoGroup at > outDegrees(Graph.java:625))(14/16) switched to RUNNING > 03/10/2015 13:44:04 CoGroup (CoGroup at > outDegrees(Graph.java:625))(13/16) switched to RUNNING > 03/10/2015 13:44:04 CoGroup (CoGroup at > outDegrees(Graph.java:625))(1/16) switched to RUNNING > 03/10/2015 13:44:04 CoGroup (CoGroup at > outDegrees(Graph.java:625))(12/16) switched to RUNNING > 03/10/2015 13:44:04 CoGroup (CoGroup at > outDegrees(Graph.java:625))(11/16) switched to RUNNING > 03/10/2015 13:44:04 CoGroup (CoGroup at > outDegrees(Graph.java:625))(10/16) switched to RUNNING > 03/10/2015 13:44:04 CoGroup (CoGroup at > outDegrees(Graph.java:625))(9/16) switched to RUNNING > 03/10/2015 13:44:04 CoGroup (CoGroup at > outDegrees(Graph.java:625))(8/16) switched to RUNNING > 03/10/2015 13:44:04 DataSource (at > getLongLongEdgeInvalidSrcData(TestGraphUtils.java:53) > (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to > FINISHED > 03/10/2015 13:44:04 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(11/16) > switched to SCHEDULED > 03/10/2015 13:44:04 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(11/16) > switched to DEPLOYING > 03/10/2015 13:44:04 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(16/16) > switched to SCHEDULED > 03/10/2015 13:44:04 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(16/16) > switched to DEPLOYING > 03/10/2015 13:44:04 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(7/16) > switched to SCHEDULED > 03/10/2015 13:44:04 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(7/16) > switched to DEPLOYING > 03/10/2015 13:44:04 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(15/16) > switched to SCHEDULED > 03/10/2015 13:44:04 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(15/16) > switched to DEPLOYING > 03/10/2015 13:44:04 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(14/16) > switched to SCHEDULED > 03/10/2015 13:44:04 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(14/16) > switched to DEPLOYING > 03/10/2015 13:44:04 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(13/16) > switched to SCHEDULED > 03/10/2015 13:44:04 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(13/16) > switched to DEPLOYING > 03/10/2015 13:44:04 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(5/16) > switched to SCHEDULED > 03/10/2015 13:44:04 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(5/16) > switched to DEPLOYING > 03/10/2015 13:44:04 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(12/16) > switched to SCHEDULED > 03/10/2015 13:44:04 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(12/16) > switched to DEPLOYING > 03/10/2015 13:44:04 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(1/16) > switched to SCHEDULED > 03/10/2015 13:44:04 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(1/16) > switched to DEPLOYING > 03/10/2015 13:44:04 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(10/16) > switched to SCHEDULED > 03/10/2015 13:44:04 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(10/16) > switched to DEPLOYING > 03/10/2015 13:44:04 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(6/16) > switched to SCHEDULED > 03/10/2015 13:44:04 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(6/16) > switched to DEPLOYING > 03/10/2015 13:44:04 DataSource (at > getLongLongVertexData(TestGraphUtils.java:37) > (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to > FINISHED > 03/10/2015 13:44:04 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(8/16) > switched to SCHEDULED > 03/10/2015 13:44:04 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(8/16) > switched to DEPLOYING > 03/10/2015 13:44:04 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(4/16) > switched to SCHEDULED > 03/10/2015 13:44:04 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(4/16) > switched to DEPLOYING > 03/10/2015 13:44:04 CoGroup (CoGroup at > outDegrees(Graph.java:625))(7/16) switched to FINISHED > 03/10/2015 13:44:04 CoGroup (CoGroup at > outDegrees(Graph.java:625))(16/16) switched to FINISHED > 03/10/2015 13:44:04 CoGroup (CoGroup at > outDegrees(Graph.java:625))(15/16) switched to FINISHED > 03/10/2015 13:44:04 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(11/16) > switched to RUNNING > 03/10/2015 13:44:04 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(16/16) > switched to RUNNING > 03/10/2015 13:44:04 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(7/16) > switched to RUNNING > 03/10/2015 13:44:04 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(15/16) > switched to RUNNING > 03/10/2015 13:44:04 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(14/16) > switched to RUNNING > 03/10/2015 13:44:04 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(13/16) > switched to RUNNING > 03/10/2015 13:44:05 CoGroup (CoGroup at > outDegrees(Graph.java:625))(1/16) switched to FINISHED > 03/10/2015 13:44:05 CoGroup (CoGroup at > outDegrees(Graph.java:625))(12/16) switched to FINISHED > 03/10/2015 13:44:05 CoGroup (CoGroup at > outDegrees(Graph.java:625))(10/16) switched to FINISHED > 03/10/2015 13:44:05 CoGroup (CoGroup at > outDegrees(Graph.java:625))(11/16) switched to FINISHED > 03/10/2015 13:44:05 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(5/16) > switched to RUNNING > 03/10/2015 13:44:05 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(12/16) > switched to RUNNING > 03/10/2015 13:44:05 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(1/16) > switched to RUNNING > 03/10/2015 13:44:05 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(10/16) > switched to RUNNING > 03/10/2015 13:44:05 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(6/16) > switched to RUNNING > 03/10/2015 13:44:05 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(8/16) > switched to RUNNING > 03/10/2015 13:44:05 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(4/16) > switched to RUNNING > 03/10/2015 13:44:05 CoGroup (CoGroup at > outDegrees(Graph.java:625))(5/16) switched to FINISHED > 03/10/2015 13:44:05 CoGroup (CoGroup at > outDegrees(Graph.java:625))(13/16) switched to FINISHED > 03/10/2015 13:44:05 CoGroup (CoGroup at > outDegrees(Graph.java:625))(14/16) switched to FINISHED > 03/10/2015 13:44:05 CoGroup (CoGroup at > outDegrees(Graph.java:625))(8/16) switched to FINISHED > 03/10/2015 13:44:05 CoGroup (CoGroup at > outDegrees(Graph.java:625))(9/16) switched to FAILED > java.util.NoSuchElementException: The edge src/trg id could not be > found within the vertexIds > at > org.apache.flink.graph.Graph$CountNeighborsCoGroup.coGroup(Graph.java:643) > at > org.apache.flink.runtime.operators.CoGroupDriver.run(CoGroupDriver.java:152) > at > org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:496) > at > org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:362) > at > org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:205) > at java.lang.Thread.run(Thread.java:701) > > 03/10/2015 13:44:05 Job execution switched to status FAILING. > 03/10/2015 13:44:05 CoGroup (CoGroup at > outDegrees(Graph.java:625))(2/16) switched to CANCELING > 03/10/2015 13:44:05 CoGroup (CoGroup at > outDegrees(Graph.java:625))(3/16) switched to CANCELING > 03/10/2015 13:44:05 CoGroup (CoGroup at > outDegrees(Graph.java:625))(4/16) switched to CANCELING > 03/10/2015 13:44:05 CoGroup (CoGroup at > outDegrees(Graph.java:625))(6/16) switched to CANCELING > 03/10/2015 13:44:05 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(1/16) > switched to CANCELING > 03/10/2015 13:44:05 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(2/16) > switched to CANCELED > 03/10/2015 13:44:05 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(3/16) > switched to CANCELED > 03/10/2015 13:44:05 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(4/16) > switched to CANCELING > 03/10/2015 13:44:05 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(5/16) > switched to CANCELING > 03/10/2015 13:44:05 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(6/16) > switched to CANCELING > 03/10/2015 13:44:05 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(7/16) > switched to CANCELING > 03/10/2015 13:44:05 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(8/16) > switched to CANCELING > 03/10/2015 13:44:05 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(11/16) > switched to FINISHED > 03/10/2015 13:44:05 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(16/16) > switched to FINISHED > 03/10/2015 13:44:05 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(7/16) > switched to CANCELED > 03/10/2015 13:44:05 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(15/16) > switched to FINISHED > 03/10/2015 13:44:05 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(14/16) > switched to FINISHED > 03/10/2015 13:44:05 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(13/16) > switched to FINISHED > 03/10/2015 13:44:05 CoGroup (CoGroup at > outDegrees(Graph.java:625))(4/16) switched to CANCELED > 03/10/2015 13:44:05 CoGroup (CoGroup at > outDegrees(Graph.java:625))(6/16) switched to CANCELED > 03/10/2015 13:44:05 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(5/16) > switched to CANCELED > 03/10/2015 13:44:05 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(12/16) > switched to FINISHED > 03/10/2015 13:44:05 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(1/16) > switched to CANCELED > 03/10/2015 13:44:05 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(10/16) > switched to FINISHED > 03/10/2015 13:44:05 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(6/16) > switched to CANCELED > 03/10/2015 13:44:05 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(8/16) > switched to CANCELED > 03/10/2015 13:44:05 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(4/16) > switched to CANCELED > 03/10/2015 13:44:05 CoGroup (CoGroup at > outDegrees(Graph.java:625))(2/16) switched to CANCELED > 03/10/2015 13:44:05 CoGroup (CoGroup at > outDegrees(Graph.java:625))(3/16) switched to CANCELED > 03/10/2015 13:44:05 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@923288b > )(9/16) > switched to CANCELED > 03/10/2015 13:44:05 Job execution switched to status FAILED. > 03/10/2015 13:44:05 Job execution switched to status RUNNING. > 03/10/2015 13:44:05 DataSource (at > getLongLongVertexData(TestGraphUtils.java:37) > (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to > SCHEDULED > 03/10/2015 13:44:05 DataSource (at > getLongLongVertexData(TestGraphUtils.java:37) > (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to > DEPLOYING > 03/10/2015 13:44:05 DataSource (at > getLongLongEdgeInvalidTrgData(TestGraphUtils.java:63) > (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to > SCHEDULED > 03/10/2015 13:44:05 DataSource (at > getLongLongEdgeInvalidTrgData(TestGraphUtils.java:63) > (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to > DEPLOYING > 03/10/2015 13:44:05 DataSource (at > getLongLongVertexData(TestGraphUtils.java:37) > (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to > RUNNING > 03/10/2015 13:44:05 DataSource (at > getLongLongEdgeInvalidTrgData(TestGraphUtils.java:63) > (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to > RUNNING > 03/10/2015 13:44:05 CoGroup (CoGroup at > inDegrees(Graph.java:655))(1/16) switched to SCHEDULED > 03/10/2015 13:44:05 CoGroup (CoGroup at > inDegrees(Graph.java:655))(2/16) switched to SCHEDULED > 03/10/2015 13:44:05 CoGroup (CoGroup at > inDegrees(Graph.java:655))(3/16) switched to SCHEDULED > 03/10/2015 13:44:05 CoGroup (CoGroup at > inDegrees(Graph.java:655))(4/16) switched to SCHEDULED > 03/10/2015 13:44:05 CoGroup (CoGroup at > inDegrees(Graph.java:655))(5/16) switched to SCHEDULED > 03/10/2015 13:44:05 CoGroup (CoGroup at > inDegrees(Graph.java:655))(6/16) switched to SCHEDULED > 03/10/2015 13:44:05 CoGroup (CoGroup at > inDegrees(Graph.java:655))(7/16) switched to SCHEDULED > 03/10/2015 13:44:05 CoGroup (CoGroup at > inDegrees(Graph.java:655))(8/16) switched to SCHEDULED > 03/10/2015 13:44:05 CoGroup (CoGroup at > inDegrees(Graph.java:655))(9/16) switched to SCHEDULED > 03/10/2015 13:44:05 CoGroup (CoGroup at > inDegrees(Graph.java:655))(10/16) switched to SCHEDULED > 03/10/2015 13:44:05 CoGroup (CoGroup at > inDegrees(Graph.java:655))(11/16) switched to SCHEDULED > 03/10/2015 13:44:05 CoGroup (CoGroup at > inDegrees(Graph.java:655))(12/16) switched to SCHEDULED > 03/10/2015 13:44:05 CoGroup (CoGroup at > inDegrees(Graph.java:655))(13/16) switched to SCHEDULED > 03/10/2015 13:44:05 CoGroup (CoGroup at > inDegrees(Graph.java:655))(14/16) switched to SCHEDULED > 03/10/2015 13:44:05 CoGroup (CoGroup at > inDegrees(Graph.java:655))(15/16) switched to SCHEDULED > 03/10/2015 13:44:05 CoGroup (CoGroup at > inDegrees(Graph.java:655))(16/16) switched to SCHEDULED > 03/10/2015 13:44:05 CoGroup (CoGroup at > inDegrees(Graph.java:655))(1/16) switched to DEPLOYING > 03/10/2015 13:44:05 CoGroup (CoGroup at > inDegrees(Graph.java:655))(16/16) switched to DEPLOYING > 03/10/2015 13:44:05 CoGroup (CoGroup at > inDegrees(Graph.java:655))(15/16) switched to DEPLOYING > 03/10/2015 13:44:05 CoGroup (CoGroup at > inDegrees(Graph.java:655))(14/16) switched to DEPLOYING > 03/10/2015 13:44:05 CoGroup (CoGroup at > inDegrees(Graph.java:655))(13/16) switched to DEPLOYING > 03/10/2015 13:44:05 CoGroup (CoGroup at > inDegrees(Graph.java:655))(12/16) switched to DEPLOYING > 03/10/2015 13:44:05 CoGroup (CoGroup at > inDegrees(Graph.java:655))(11/16) switched to DEPLOYING > 03/10/2015 13:44:05 CoGroup (CoGroup at > inDegrees(Graph.java:655))(10/16) switched to DEPLOYING > 03/10/2015 13:44:05 CoGroup (CoGroup at > inDegrees(Graph.java:655))(9/16) switched to DEPLOYING > 03/10/2015 13:44:05 CoGroup (CoGroup at > inDegrees(Graph.java:655))(8/16) switched to DEPLOYING > 03/10/2015 13:44:05 CoGroup (CoGroup at > inDegrees(Graph.java:655))(7/16) switched to DEPLOYING > 03/10/2015 13:44:05 CoGroup (CoGroup at > inDegrees(Graph.java:655))(6/16) switched to DEPLOYING > 03/10/2015 13:44:05 CoGroup (CoGroup at > inDegrees(Graph.java:655))(5/16) switched to DEPLOYING > 03/10/2015 13:44:05 CoGroup (CoGroup at > inDegrees(Graph.java:655))(4/16) switched to DEPLOYING > 03/10/2015 13:44:05 CoGroup (CoGroup at > inDegrees(Graph.java:655))(3/16) switched to DEPLOYING > 03/10/2015 13:44:05 CoGroup (CoGroup at > inDegrees(Graph.java:655))(2/16) switched to DEPLOYING > Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 5.853 > sec - in org.apache.flink.graph.test.example.LabelPropagationExampleITCase > 03/10/2015 13:44:05 CoGroup (CoGroup at > inDegrees(Graph.java:655))(2/16) switched to RUNNING > 03/10/2015 13:44:05 CoGroup (CoGroup at > inDegrees(Graph.java:655))(3/16) switched to RUNNING > 03/10/2015 13:44:05 CoGroup (CoGroup at > inDegrees(Graph.java:655))(4/16) switched to RUNNING > 03/10/2015 13:44:05 CoGroup (CoGroup at > inDegrees(Graph.java:655))(5/16) switched to RUNNING > 03/10/2015 13:44:05 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(2/16) > switched to SCHEDULED > 03/10/2015 13:44:05 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(2/16) > switched to DEPLOYING > 03/10/2015 13:44:05 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(3/16) > switched to SCHEDULED > 03/10/2015 13:44:05 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(3/16) > switched to DEPLOYING > 03/10/2015 13:44:05 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(4/16) > switched to SCHEDULED > 03/10/2015 13:44:05 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(4/16) > switched to DEPLOYING > 03/10/2015 13:44:05 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(5/16) > switched to SCHEDULED > 03/10/2015 13:44:05 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(5/16) > switched to DEPLOYING > 03/10/2015 13:44:05 CoGroup (CoGroup at > inDegrees(Graph.java:655))(6/16) switched to RUNNING > 03/10/2015 13:44:05 CoGroup (CoGroup at > inDegrees(Graph.java:655))(7/16) switched to RUNNING > 03/10/2015 13:44:05 CoGroup (CoGroup at > inDegrees(Graph.java:655))(9/16) switched to RUNNING > 03/10/2015 13:44:05 DataSource (at > getLongLongEdgeInvalidTrgData(TestGraphUtils.java:63) > (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to > FINISHED > 03/10/2015 13:44:05 CoGroup (CoGroup at > inDegrees(Graph.java:655))(8/16) switched to RUNNING > 03/10/2015 13:44:05 CoGroup (CoGroup at > inDegrees(Graph.java:655))(10/16) switched to RUNNING > 03/10/2015 13:44:05 CoGroup (CoGroup at > inDegrees(Graph.java:655))(11/16) switched to RUNNING > 03/10/2015 13:44:05 CoGroup (CoGroup at > inDegrees(Graph.java:655))(12/16) switched to RUNNING > 03/10/2015 13:44:06 CoGroup (CoGroup at > inDegrees(Graph.java:655))(13/16) switched to RUNNING > 03/10/2015 13:44:06 CoGroup (CoGroup at > inDegrees(Graph.java:655))(14/16) switched to RUNNING > 03/10/2015 13:44:06 CoGroup (CoGroup at > inDegrees(Graph.java:655))(15/16) switched to RUNNING > 03/10/2015 13:44:06 CoGroup (CoGroup at > inDegrees(Graph.java:655))(16/16) switched to RUNNING > 03/10/2015 13:44:06 CoGroup (CoGroup at > inDegrees(Graph.java:655))(1/16) switched to RUNNING > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(2/16) > switched to RUNNING > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(3/16) > switched to RUNNING > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(4/16) > switched to RUNNING > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(5/16) > switched to RUNNING > Running org.apache.flink.graph.test.WeaklyConnectedITCase > 03/10/2015 13:44:06 DataSource (at > getLongLongVertexData(TestGraphUtils.java:37) > (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to > FINISHED > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(6/16) > switched to SCHEDULED > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(6/16) > switched to DEPLOYING > 03/10/2015 13:44:06 CoGroup (CoGroup at > inDegrees(Graph.java:655))(5/16) switched to FINISHED > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(4/16) > switched to FINISHED > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(1/16) > switched to SCHEDULED > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(1/16) > switched to DEPLOYING > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(16/16) > switched to SCHEDULED > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(16/16) > switched to DEPLOYING > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(7/16) > switched to SCHEDULED > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(7/16) > switched to DEPLOYING > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(10/16) > switched to SCHEDULED > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(13/16) > switched to SCHEDULED > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(13/16) > switched to DEPLOYING > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(14/16) > switched to SCHEDULED > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(14/16) > switched to DEPLOYING > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(8/16) > switched to SCHEDULED > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(8/16) > switched to DEPLOYING > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(15/16) > switched to SCHEDULED > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(15/16) > switched to DEPLOYING > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(11/16) > switched to SCHEDULED > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(11/16) > switched to DEPLOYING > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(12/16) > switched to SCHEDULED > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(12/16) > switched to DEPLOYING > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(10/16) > switched to DEPLOYING > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(3/16) > switched to FINISHED > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(7/16) > switched to RUNNING > 03/10/2015 13:44:06 CoGroup (CoGroup at > inDegrees(Graph.java:655))(2/16) switched to FINISHED > 03/10/2015 13:44:06 CoGroup (CoGroup at > inDegrees(Graph.java:655))(4/16) switched to FINISHED > 03/10/2015 13:44:06 CoGroup (CoGroup at > inDegrees(Graph.java:655))(3/16) switched to FINISHED > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(7/16) > switched to FINISHED > 03/10/2015 13:44:06 CoGroup (CoGroup at > inDegrees(Graph.java:655))(8/16) switched to FINISHED > 03/10/2015 13:44:06 CoGroup (CoGroup at > inDegrees(Graph.java:655))(16/16) switched to FINISHED > 03/10/2015 13:44:06 CoGroup (CoGroup at > inDegrees(Graph.java:655))(1/16) switched to FINISHED > 03/10/2015 13:44:06 CoGroup (CoGroup at > inDegrees(Graph.java:655))(15/16) switched to FINISHED > 03/10/2015 13:44:06 CoGroup (CoGroup at > inDegrees(Graph.java:655))(12/16) switched to FINISHED > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(2/16) > switched to FINISHED > 03/10/2015 13:44:06 CoGroup (CoGroup at > inDegrees(Graph.java:655))(11/16) switched to FINISHED > 03/10/2015 13:44:06 CoGroup (CoGroup at > inDegrees(Graph.java:655))(7/16) switched to FINISHED > 03/10/2015 13:44:06 CoGroup (CoGroup at > inDegrees(Graph.java:655))(10/16) switched to FINISHED > 03/10/2015 13:44:06 CoGroup (CoGroup at > inDegrees(Graph.java:655))(13/16) switched to FINISHED > 03/10/2015 13:44:06 CoGroup (CoGroup at > inDegrees(Graph.java:655))(14/16) switched to FINISHED > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(10/16) > switched to RUNNING > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(12/16) > switched to RUNNING > 03/10/2015 13:44:06 CoGroup (CoGroup at > inDegrees(Graph.java:655))(6/16) switched to FINISHED > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(11/16) > switched to RUNNING > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(15/16) > switched to RUNNING > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(8/16) > switched to RUNNING > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(14/16) > switched to RUNNING > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(13/16) > switched to RUNNING > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(16/16) > switched to RUNNING > 03/10/2015 13:44:06 CoGroup (CoGroup at > inDegrees(Graph.java:655))(9/16) switched to FAILED > java.util.NoSuchElementException: The edge src/trg id could not be > found within the vertexIds > at > org.apache.flink.graph.Graph$CountNeighborsCoGroup.coGroup(Graph.java:643) > at > org.apache.flink.runtime.operators.CoGroupDriver.run(CoGroupDriver.java:152) > at > org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:496) > at > org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:362) > at > org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:205) > at java.lang.Thread.run(Thread.java:701) > > 03/10/2015 13:44:06 Job execution switched to status FAILING. > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(1/16) > switched to CANCELING > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(5/16) > switched to CANCELING > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(6/16) > switched to CANCELING > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(8/16) > switched to CANCELING > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(9/16) > switched to CANCELED > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(10/16) > switched to CANCELING > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(11/16) > switched to CANCELING > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(12/16) > switched to CANCELING > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(13/16) > switched to CANCELING > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(14/16) > switched to CANCELING > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(15/16) > switched to CANCELING > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(16/16) > switched to CANCELING > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(5/16) > switched to CANCELED > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(15/16) > switched to CANCELED > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(11/16) > switched to CANCELED > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(12/16) > switched to CANCELED > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(16/16) > switched to CANCELED > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(1/16) > switched to CANCELED > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(10/16) > switched to CANCELED > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(8/16) > switched to CANCELED > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(14/16) > switched to CANCELED > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(13/16) > switched to CANCELED > 03/10/2015 13:44:06 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@48f46b9 > )(6/16) > switched to CANCELED > 03/10/2015 13:44:06 Job execution switched to status FAILED. > 03/10/2015 13:44:07 Job execution switched to status RUNNING. > 03/10/2015 13:44:07 DataSource (at > getLongLongEdgeInvalidSrcData(TestGraphUtils.java:53) > (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to > SCHEDULED > 03/10/2015 13:44:07 DataSource (at > getLongLongEdgeInvalidSrcData(TestGraphUtils.java:53) > (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to > DEPLOYING > 03/10/2015 13:44:07 DataSource (at > getLongLongVertexData(TestGraphUtils.java:37) > (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to > SCHEDULED > 03/10/2015 13:44:07 DataSource (at > getLongLongVertexData(TestGraphUtils.java:37) > (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to > DEPLOYING > 03/10/2015 13:44:07 DataSource (at > getLongLongEdgeInvalidSrcData(TestGraphUtils.java:53) > (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to > RUNNING > 03/10/2015 13:44:07 DataSource (at > getLongLongVertexData(TestGraphUtils.java:37) > (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to > RUNNING > 03/10/2015 13:44:07 CoGroup (CoGroup at > outDegrees(Graph.java:625))(1/16) switched to SCHEDULED > 03/10/2015 13:44:07 CoGroup (CoGroup at > outDegrees(Graph.java:625))(1/16) switched to DEPLOYING > 03/10/2015 13:44:07 CoGroup (CoGroup at > outDegrees(Graph.java:625))(2/16) switched to SCHEDULED > 03/10/2015 13:44:07 CoGroup (CoGroup at > outDegrees(Graph.java:625))(2/16) switched to DEPLOYING > 03/10/2015 13:44:07 CoGroup (CoGroup at > outDegrees(Graph.java:625))(3/16) switched to SCHEDULED > 03/10/2015 13:44:07 CoGroup (CoGroup at > outDegrees(Graph.java:625))(3/16) switched to DEPLOYING > 03/10/2015 13:44:07 CoGroup (CoGroup at > outDegrees(Graph.java:625))(4/16) switched to SCHEDULED > 03/10/2015 13:44:07 CoGroup (CoGroup at > outDegrees(Graph.java:625))(4/16) switched to DEPLOYING > 03/10/2015 13:44:07 CoGroup (CoGroup at > outDegrees(Graph.java:625))(5/16) switched to SCHEDULED > 03/10/2015 13:44:07 CoGroup (CoGroup at > outDegrees(Graph.java:625))(5/16) switched to DEPLOYING > 03/10/2015 13:44:07 CoGroup (CoGroup at > outDegrees(Graph.java:625))(6/16) switched to SCHEDULED > 03/10/2015 13:44:07 CoGroup (CoGroup at > outDegrees(Graph.java:625))(6/16) switched to DEPLOYING > 03/10/2015 13:44:07 CoGroup (CoGroup at > outDegrees(Graph.java:625))(7/16) switched to SCHEDULED > 03/10/2015 13:44:07 CoGroup (CoGroup at > outDegrees(Graph.java:625))(7/16) switched to DEPLOYING > 03/10/2015 13:44:07 CoGroup (CoGroup at > outDegrees(Graph.java:625))(8/16) switched to SCHEDULED > 03/10/2015 13:44:07 CoGroup (CoGroup at > outDegrees(Graph.java:625))(8/16) switched to DEPLOYING > 03/10/2015 13:44:07 CoGroup (CoGroup at > outDegrees(Graph.java:625))(9/16) switched to SCHEDULED > 03/10/2015 13:44:07 CoGroup (CoGroup at > outDegrees(Graph.java:625))(9/16) switched to DEPLOYING > 03/10/2015 13:44:07 CoGroup (CoGroup at > outDegrees(Graph.java:625))(10/16) switched to SCHEDULED > 03/10/2015 13:44:07 CoGroup (CoGroup at > outDegrees(Graph.java:625))(10/16) switched to DEPLOYING > 03/10/2015 13:44:07 CoGroup (CoGroup at > outDegrees(Graph.java:625))(11/16) switched to SCHEDULED > 03/10/2015 13:44:07 CoGroup (CoGroup at > outDegrees(Graph.java:625))(11/16) switched to DEPLOYING > 03/10/2015 13:44:07 CoGroup (CoGroup at > outDegrees(Graph.java:625))(12/16) switched to SCHEDULED > 03/10/2015 13:44:07 CoGroup (CoGroup at > outDegrees(Graph.java:625))(12/16) switched to DEPLOYING > 03/10/2015 13:44:07 CoGroup (CoGroup at > outDegrees(Graph.java:625))(13/16) switched to SCHEDULED > 03/10/2015 13:44:07 CoGroup (CoGroup at > outDegrees(Graph.java:625))(13/16) switched to DEPLOYING > 03/10/2015 13:44:07 CoGroup (CoGroup at > outDegrees(Graph.java:625))(14/16) switched to SCHEDULED > 03/10/2015 13:44:07 CoGroup (CoGroup at > outDegrees(Graph.java:625))(15/16) switched to SCHEDULED > 03/10/2015 13:44:07 CoGroup (CoGroup at > outDegrees(Graph.java:625))(14/16) switched to DEPLOYING > 03/10/2015 13:44:07 CoGroup (CoGroup at > outDegrees(Graph.java:625))(15/16) switched to DEPLOYING > 03/10/2015 13:44:07 CoGroup (CoGroup at > outDegrees(Graph.java:625))(16/16) switched to SCHEDULED > 03/10/2015 13:44:07 CoGroup (CoGroup at > outDegrees(Graph.java:625))(16/16) switched to DEPLOYING > 03/10/2015 13:44:07 CoGroup (CoGroup at > inDegrees(Graph.java:655))(1/16) switched to SCHEDULED > 03/10/2015 13:44:07 CoGroup (CoGroup at > inDegrees(Graph.java:655))(1/16) switched to DEPLOYING > 03/10/2015 13:44:07 CoGroup (CoGroup at > inDegrees(Graph.java:655))(2/16) switched to SCHEDULED > 03/10/2015 13:44:07 CoGroup (CoGroup at > inDegrees(Graph.java:655))(2/16) switched to DEPLOYING > 03/10/2015 13:44:07 CoGroup (CoGroup at > inDegrees(Graph.java:655))(3/16) switched to SCHEDULED > 03/10/2015 13:44:07 CoGroup (CoGroup at > inDegrees(Graph.java:655))(4/16) switched to SCHEDULED > 03/10/2015 13:44:07 CoGroup (CoGroup at > inDegrees(Graph.java:655))(3/16) switched to DEPLOYING > 03/10/2015 13:44:07 CoGroup (CoGroup at > inDegrees(Graph.java:655))(4/16) switched to DEPLOYING > 03/10/2015 13:44:07 CoGroup (CoGroup at > inDegrees(Graph.java:655))(5/16) switched to SCHEDULED > 03/10/2015 13:44:07 CoGroup (CoGroup at > inDegrees(Graph.java:655))(5/16) switched to DEPLOYING > 03/10/2015 13:44:07 CoGroup (CoGroup at > inDegrees(Graph.java:655))(6/16) switched to SCHEDULED > 03/10/2015 13:44:07 CoGroup (CoGroup at > inDegrees(Graph.java:655))(6/16) switched to DEPLOYING > 03/10/2015 13:44:07 CoGroup (CoGroup at > inDegrees(Graph.java:655))(7/16) switched to SCHEDULED > 03/10/2015 13:44:07 CoGroup (CoGroup at > inDegrees(Graph.java:655))(7/16) switched to DEPLOYING > 03/10/2015 13:44:07 CoGroup (CoGroup at > inDegrees(Graph.java:655))(8/16) switched to SCHEDULED > 03/10/2015 13:44:07 CoGroup (CoGroup at > inDegrees(Graph.java:655))(8/16) switched to DEPLOYING > 03/10/2015 13:44:07 CoGroup (CoGroup at > inDegrees(Graph.java:655))(9/16) switched to SCHEDULED > 03/10/2015 13:44:07 CoGroup (CoGroup at > inDegrees(Graph.java:655))(9/16) switched to DEPLOYING > 03/10/2015 13:44:07 CoGroup (CoGroup at > inDegrees(Graph.java:655))(10/16) switched to SCHEDULED > 03/10/2015 13:44:07 CoGroup (CoGroup at > inDegrees(Graph.java:655))(10/16) switched to DEPLOYING > 03/10/2015 13:44:07 CoGroup (CoGroup at > inDegrees(Graph.java:655))(11/16) switched to SCHEDULED > 03/10/2015 13:44:07 CoGroup (CoGroup at > inDegrees(Graph.java:655))(11/16) switched to DEPLOYING > 03/10/2015 13:44:07 CoGroup (CoGroup at > inDegrees(Graph.java:655))(12/16) switched to SCHEDULED > 03/10/2015 13:44:07 CoGroup (CoGroup at > inDegrees(Graph.java:655))(12/16) switched to DEPLOYING > 03/10/2015 13:44:07 CoGroup (CoGroup at > inDegrees(Graph.java:655))(13/16) switched to SCHEDULED > 03/10/2015 13:44:07 CoGroup (CoGroup at > inDegrees(Graph.java:655))(13/16) switched to DEPLOYING > 03/10/2015 13:44:07 CoGroup (CoGroup at > inDegrees(Graph.java:655))(14/16) switched to SCHEDULED > 03/10/2015 13:44:07 CoGroup (CoGroup at > inDegrees(Graph.java:655))(14/16) switched to DEPLOYING > 03/10/2015 13:44:07 CoGroup (CoGroup at > inDegrees(Graph.java:655))(15/16) switched to SCHEDULED > 03/10/2015 13:44:07 CoGroup (CoGroup at > inDegrees(Graph.java:655))(15/16) switched to DEPLOYING > 03/10/2015 13:44:07 CoGroup (CoGroup at > inDegrees(Graph.java:655))(16/16) switched to SCHEDULED > 03/10/2015 13:44:07 CoGroup (CoGroup at > inDegrees(Graph.java:655))(16/16) switched to DEPLOYING > 03/10/2015 13:44:07 CoGroup (CoGroup at > outDegrees(Graph.java:625))(16/16) switched to RUNNING > 03/10/2015 13:44:07 CoGroup (CoGroup at > outDegrees(Graph.java:625))(15/16) switched to RUNNING > 03/10/2015 13:44:07 CoGroup (CoGroup at > inDegrees(Graph.java:655))(1/16) switched to RUNNING > 03/10/2015 13:44:07 CoGroup (CoGroup at > inDegrees(Graph.java:655))(2/16) switched to RUNNING > 03/10/2015 13:44:07 Reduce(SUM(1), at getDegrees(Graph.java:664)(1/16) > switched to SCHEDULED > 03/10/2015 13:44:07 Reduce(SUM(1), at getDegrees(Graph.java:664)(1/16) > switched to DEPLOYING > 03/10/2015 13:44:07 Reduce(SUM(1), at getDegrees(Graph.java:664)(2/16) > switched to SCHEDULED > 03/10/2015 13:44:07 Reduce(SUM(1), at getDegrees(Graph.java:664)(2/16) > switched to DEPLOYING > 03/10/2015 13:44:07 Reduce(SUM(1), at getDegrees(Graph.java:664)(3/16) > switched to SCHEDULED > 03/10/2015 13:44:07 Reduce(SUM(1), at getDegrees(Graph.java:664)(3/16) > switched to DEPLOYING > 03/10/2015 13:44:07 Reduce(SUM(1), at getDegrees(Graph.java:664)(4/16) > switched to SCHEDULED > 03/10/2015 13:44:07 Reduce(SUM(1), at getDegrees(Graph.java:664)(4/16) > switched to DEPLOYING > 03/10/2015 13:44:07 Reduce(SUM(1), at getDegrees(Graph.java:664)(5/16) > switched to SCHEDULED > 03/10/2015 13:44:07 Reduce(SUM(1), at getDegrees(Graph.java:664)(5/16) > switched to DEPLOYING > 03/10/2015 13:44:07 Reduce(SUM(1), at getDegrees(Graph.java:664)(6/16) > switched to SCHEDULED > 03/10/2015 13:44:07 Reduce(SUM(1), at getDegrees(Graph.java:664)(6/16) > switched to DEPLOYING > 03/10/2015 13:44:07 Reduce(SUM(1), at getDegrees(Graph.java:664)(7/16) > switched to SCHEDULED > 03/10/2015 13:44:07 Reduce(SUM(1), at getDegrees(Graph.java:664)(7/16) > switched to DEPLOYING > 03/10/2015 13:44:07 Reduce(SUM(1), at getDegrees(Graph.java:664)(8/16) > switched to SCHEDULED > 03/10/2015 13:44:07 Reduce(SUM(1), at getDegrees(Graph.java:664)(8/16) > switched to DEPLOYING > 03/10/2015 13:44:07 Reduce(SUM(1), at getDegrees(Graph.java:664)(9/16) > switched to SCHEDULED > 03/10/2015 13:44:07 Reduce(SUM(1), at getDegrees(Graph.java:664)(9/16) > switched to DEPLOYING > 03/10/2015 13:44:07 Reduce(SUM(1), at > getDegrees(Graph.java:664)(10/16) switched to SCHEDULED > 03/10/2015 13:44:07 Reduce(SUM(1), at > getDegrees(Graph.java:664)(10/16) switched to DEPLOYING > 03/10/2015 13:44:07 Reduce(SUM(1), at > getDegrees(Graph.java:664)(11/16) switched to SCHEDULED > 03/10/2015 13:44:07 Reduce(SUM(1), at > getDegrees(Graph.java:664)(12/16) switched to SCHEDULED > 03/10/2015 13:44:07 Reduce(SUM(1), at > getDegrees(Graph.java:664)(11/16) switched to DEPLOYING > 03/10/2015 13:44:07 Reduce(SUM(1), at > getDegrees(Graph.java:664)(12/16) switched to DEPLOYING > 03/10/2015 13:44:07 Reduce(SUM(1), at > getDegrees(Graph.java:664)(13/16) switched to SCHEDULED > 03/10/2015 13:44:07 Reduce(SUM(1), at > getDegrees(Graph.java:664)(14/16) switched to SCHEDULED > 03/10/2015 13:44:07 Reduce(SUM(1), at > getDegrees(Graph.java:664)(13/16) switched to DEPLOYING > 03/10/2015 13:44:07 Reduce(SUM(1), at > getDegrees(Graph.java:664)(15/16) switched to SCHEDULED > 03/10/2015 13:44:07 Reduce(SUM(1), at > getDegrees(Graph.java:664)(15/16) switched to DEPLOYING > 03/10/2015 13:44:07 Reduce(SUM(1), at > getDegrees(Graph.java:664)(16/16) switched to SCHEDULED > 03/10/2015 13:44:07 Reduce(SUM(1), at > getDegrees(Graph.java:664)(16/16) switched to DEPLOYING > 03/10/2015 13:44:07 Reduce(SUM(1), at > getDegrees(Graph.java:664)(14/16) switched to DEPLOYING > 03/10/2015 13:44:07 CoGroup (CoGroup at > inDegrees(Graph.java:655))(4/16) switched to RUNNING > 03/10/2015 13:44:07 CoGroup (CoGroup at > inDegrees(Graph.java:655))(5/16) switched to RUNNING > 03/10/2015 13:44:07 CoGroup (CoGroup at > inDegrees(Graph.java:655))(6/16) switched to RUNNING > 03/10/2015 13:44:07 CoGroup (CoGroup at > inDegrees(Graph.java:655))(7/16) switched to RUNNING > 03/10/2015 13:44:07 CoGroup (CoGroup at > inDegrees(Graph.java:655))(8/16) switched to RUNNING > 03/10/2015 13:44:07 CoGroup (CoGroup at > inDegrees(Graph.java:655))(9/16) switched to RUNNING > 03/10/2015 13:44:07 CoGroup (CoGroup at > inDegrees(Graph.java:655))(10/16) switched to RUNNING > 03/10/2015 13:44:07 CoGroup (CoGroup at > inDegrees(Graph.java:655))(11/16) switched to RUNNING > 03/10/2015 13:44:07 CoGroup (CoGroup at > inDegrees(Graph.java:655))(12/16) switched to RUNNING > 03/10/2015 13:44:07 CoGroup (CoGroup at > inDegrees(Graph.java:655))(13/16) switched to RUNNING > 03/10/2015 13:44:07 CoGroup (CoGroup at > inDegrees(Graph.java:655))(14/16) switched to RUNNING > 03/10/2015 13:44:07 CoGroup (CoGroup at > inDegrees(Graph.java:655))(15/16) switched to RUNNING > 03/10/2015 13:44:07 CoGroup (CoGroup at > inDegrees(Graph.java:655))(16/16) switched to RUNNING > 03/10/2015 13:44:07 CoGroup (CoGroup at > outDegrees(Graph.java:625))(14/16) switched to RUNNING > 03/10/2015 13:44:07 CoGroup (CoGroup at > outDegrees(Graph.java:625))(13/16) switched to RUNNING > 03/10/2015 13:44:07 CoGroup (CoGroup at > outDegrees(Graph.java:625))(12/16) switched to RUNNING > 03/10/2015 13:44:07 CoGroup (CoGroup at > outDegrees(Graph.java:625))(11/16) switched to RUNNING > 03/10/2015 13:44:07 CoGroup (CoGroup at > outDegrees(Graph.java:625))(10/16) switched to RUNNING > 03/10/2015 13:44:07 CoGroup (CoGroup at > outDegrees(Graph.java:625))(9/16) switched to RUNNING > 03/10/2015 13:44:07 CoGroup (CoGroup at > outDegrees(Graph.java:625))(8/16) switched to RUNNING > 03/10/2015 13:44:07 CoGroup (CoGroup at > outDegrees(Graph.java:625))(7/16) switched to RUNNING > 03/10/2015 13:44:07 CoGroup (CoGroup at > outDegrees(Graph.java:625))(6/16) switched to RUNNING > 03/10/2015 13:44:08 CoGroup (CoGroup at > outDegrees(Graph.java:625))(5/16) switched to RUNNING > 03/10/2015 13:44:08 DataSource (at > getLongLongVertexData(TestGraphUtils.java:37) > (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to > FINISHED > 03/10/2015 13:44:08 CoGroup (CoGroup at > outDegrees(Graph.java:625))(4/16) switched to RUNNING > 03/10/2015 13:44:08 CoGroup (CoGroup at > outDegrees(Graph.java:625))(3/16) switched to RUNNING > 03/10/2015 13:44:08 CoGroup (CoGroup at > outDegrees(Graph.java:625))(2/16) switched to RUNNING > 03/10/2015 13:44:08 CoGroup (CoGroup at > outDegrees(Graph.java:625))(1/16) switched to RUNNING > 03/10/2015 13:44:08 CoGroup (CoGroup at > inDegrees(Graph.java:655))(3/16) switched to RUNNING > 03/10/2015 13:44:08 DataSource (at > getLongLongEdgeInvalidSrcData(TestGraphUtils.java:53) > (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to > FINISHED > 03/10/2015 13:44:08 Reduce(SUM(1), at getDegrees(Graph.java:664)(1/16) > switched to RUNNING > 03/10/2015 13:44:08 Reduce(SUM(1), at getDegrees(Graph.java:664)(2/16) > switched to RUNNING > 03/10/2015 13:44:08 Reduce(SUM(1), at getDegrees(Graph.java:664)(3/16) > switched to RUNNING > 03/10/2015 13:44:08 Reduce(SUM(1), at getDegrees(Graph.java:664)(4/16) > switched to RUNNING > 03/10/2015 13:44:08 Reduce(SUM(1), at getDegrees(Graph.java:664)(5/16) > switched to RUNNING > 03/10/2015 13:44:08 Reduce(SUM(1), at getDegrees(Graph.java:664)(6/16) > switched to RUNNING > 03/10/2015 13:44:08 Reduce(SUM(1), at getDegrees(Graph.java:664)(7/16) > switched to RUNNING > 03/10/2015 13:44:08 Reduce(SUM(1), at getDegrees(Graph.java:664)(8/16) > switched to RUNNING > 03/10/2015 13:44:08 Reduce(SUM(1), at getDegrees(Graph.java:664)(9/16) > switched to RUNNING > 03/10/2015 13:44:08 Reduce(SUM(1), at > getDegrees(Graph.java:664)(11/16) switched to RUNNING > 03/10/2015 13:44:08 Reduce(SUM(1), at > getDegrees(Graph.java:664)(12/16) switched to RUNNING > 03/10/2015 13:44:08 Reduce(SUM(1), at > getDegrees(Graph.java:664)(13/16) switched to RUNNING > 03/10/2015 13:44:08 Reduce(SUM(1), at > getDegrees(Graph.java:664)(10/16) switched to RUNNING > 03/10/2015 13:44:08 Reduce(SUM(1), at > getDegrees(Graph.java:664)(16/16) switched to RUNNING > 03/10/2015 13:44:08 Reduce(SUM(1), at > getDegrees(Graph.java:664)(15/16) switched to RUNNING > 03/10/2015 13:44:08 CoGroup (CoGroup at > inDegrees(Graph.java:655))(2/16) switched to FINISHED > 03/10/2015 13:44:08 Reduce(SUM(1), at > getDegrees(Graph.java:664)(14/16) switched to RUNNING > 03/10/2015 13:44:08 CoGroup (CoGroup at > inDegrees(Graph.java:655))(1/16) switched to FINISHED > 03/10/2015 13:44:08 CoGroup (CoGroup at > outDegrees(Graph.java:625))(16/16) switched to FINISHED > 03/10/2015 13:44:08 CoGroup (CoGroup at > inDegrees(Graph.java:655))(4/16) switched to FINISHED > 03/10/2015 13:44:08 CoGroup (CoGroup at > outDegrees(Graph.java:625))(15/16) switched to FINISHED > 03/10/2015 13:44:08 CoGroup (CoGroup at > outDegrees(Graph.java:625))(6/16) switched to FINISHED > 03/10/2015 13:44:08 CoGroup (CoGroup at > outDegrees(Graph.java:625))(8/16) switched to FINISHED > 03/10/2015 13:44:08 CoGroup (CoGroup at > outDegrees(Graph.java:625))(10/16) switched to FINISHED > 03/10/2015 13:44:08 CoGroup (CoGroup at > outDegrees(Graph.java:625))(9/16) switched to FAILED > java.util.NoSuchElementException: The edge src/trg id could not be > found within the vertexIds > at > org.apache.flink.graph.Graph$CountNeighborsCoGroup.coGroup(Graph.java:643) > at > org.apache.flink.runtime.operators.CoGroupDriver.run(CoGroupDriver.java:152) > at > org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:496) > at > org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:362) > at > org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:205) > at java.lang.Thread.run(Thread.java:701) > > 03/10/2015 13:44:08 Job execution switched to status FAILING. > 03/10/2015 13:44:08 CoGroup (CoGroup at > outDegrees(Graph.java:625))(1/16) switched to CANCELING > 03/10/2015 13:44:08 CoGroup (CoGroup at > outDegrees(Graph.java:625))(2/16) switched to CANCELING > 03/10/2015 13:44:08 CoGroup (CoGroup at > outDegrees(Graph.java:625))(3/16) switched to CANCELING > 03/10/2015 13:44:08 CoGroup (CoGroup at > outDegrees(Graph.java:625))(4/16) switched to CANCELING > 03/10/2015 13:44:08 CoGroup (CoGroup at > outDegrees(Graph.java:625))(5/16) switched to CANCELING > 03/10/2015 13:44:08 CoGroup (CoGroup at > outDegrees(Graph.java:625))(7/16) switched to CANCELING > 03/10/2015 13:44:08 CoGroup (CoGroup at > outDegrees(Graph.java:625))(11/16) switched to CANCELING > 03/10/2015 13:44:08 CoGroup (CoGroup at > outDegrees(Graph.java:625))(12/16) switched to CANCELING > 03/10/2015 13:44:08 CoGroup (CoGroup at > outDegrees(Graph.java:625))(13/16) switched to CANCELING > 03/10/2015 13:44:08 CoGroup (CoGroup at > outDegrees(Graph.java:625))(14/16) switched to CANCELING > 03/10/2015 13:44:08 CoGroup (CoGroup at > inDegrees(Graph.java:655))(3/16) switched to CANCELING > 03/10/2015 13:44:08 CoGroup (CoGroup at > inDegrees(Graph.java:655))(5/16) switched to CANCELING > 03/10/2015 13:44:08 CoGroup (CoGroup at > inDegrees(Graph.java:655))(6/16) switched to CANCELING > 03/10/2015 13:44:08 CoGroup (CoGroup at > inDegrees(Graph.java:655))(7/16) switched to CANCELING > 03/10/2015 13:44:08 CoGroup (CoGroup at > inDegrees(Graph.java:655))(8/16) switched to CANCELING > 03/10/2015 13:44:08 CoGroup (CoGroup at > inDegrees(Graph.java:655))(9/16) switched to CANCELING > 03/10/2015 13:44:08 CoGroup (CoGroup at > inDegrees(Graph.java:655))(10/16) switched to CANCELING > 03/10/2015 13:44:08 CoGroup (CoGroup at > inDegrees(Graph.java:655))(11/16) switched to CANCELING > 03/10/2015 13:44:08 CoGroup (CoGroup at > inDegrees(Graph.java:655))(12/16) switched to CANCELING > 03/10/2015 13:44:08 CoGroup (CoGroup at > inDegrees(Graph.java:655))(13/16) switched to CANCELING > 03/10/2015 13:44:08 CoGroup (CoGroup at > inDegrees(Graph.java:655))(14/16) switched to CANCELING > 03/10/2015 13:44:08 CoGroup (CoGroup at > inDegrees(Graph.java:655))(15/16) switched to CANCELING > 03/10/2015 13:44:08 CoGroup (CoGroup at > inDegrees(Graph.java:655))(16/16) switched to CANCELING > 03/10/2015 13:44:08 Reduce(SUM(1), at getDegrees(Graph.java:664)(1/16) > switched to CANCELING > 03/10/2015 13:44:08 Reduce(SUM(1), at getDegrees(Graph.java:664)(2/16) > switched to CANCELING > 03/10/2015 13:44:08 Reduce(SUM(1), at getDegrees(Graph.java:664)(3/16) > switched to CANCELING > 03/10/2015 13:44:08 Reduce(SUM(1), at getDegrees(Graph.java:664)(4/16) > switched to CANCELING > 03/10/2015 13:44:08 Reduce(SUM(1), at getDegrees(Graph.java:664)(5/16) > switched to CANCELING > 03/10/2015 13:44:08 Reduce(SUM(1), at getDegrees(Graph.java:664)(6/16) > switched to CANCELING > 03/10/2015 13:44:08 Reduce(SUM(1), at getDegrees(Graph.java:664)(7/16) > switched to CANCELING > 03/10/2015 13:44:08 Reduce(SUM(1), at getDegrees(Graph.java:664)(8/16) > switched to CANCELING > 03/10/2015 13:44:08 Reduce(SUM(1), at getDegrees(Graph.java:664)(9/16) > switched to CANCELING > 03/10/2015 13:44:08 Reduce(SUM(1), at > getDegrees(Graph.java:664)(10/16) switched to CANCELING > 03/10/2015 13:44:08 Reduce(SUM(1), at > getDegrees(Graph.java:664)(11/16) switched to CANCELING > 03/10/2015 13:44:08 Reduce(SUM(1), at > getDegrees(Graph.java:664)(12/16) switched to CANCELING > 03/10/2015 13:44:08 Reduce(SUM(1), at > getDegrees(Graph.java:664)(13/16) switched to CANCELING > 03/10/2015 13:44:08 Reduce(SUM(1), at > getDegrees(Graph.java:664)(14/16) switched to CANCELING > 03/10/2015 13:44:08 Reduce(SUM(1), at > getDegrees(Graph.java:664)(15/16) switched to CANCELING > 03/10/2015 13:44:08 Reduce(SUM(1), at > getDegrees(Graph.java:664)(16/16) switched to CANCELING > 03/10/2015 13:44:08 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a44efd4 > )(1/16) > switched to CANCELED > 03/10/2015 13:44:08 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a44efd4 > )(2/16) > switched to CANCELED > 03/10/2015 13:44:08 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a44efd4 > )(3/16) > switched to CANCELED > 03/10/2015 13:44:08 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a44efd4 > )(4/16) > switched to CANCELED > 03/10/2015 13:44:08 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a44efd4 > )(5/16) > switched to CANCELED > 03/10/2015 13:44:08 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a44efd4 > )(6/16) > switched to CANCELED > 03/10/2015 13:44:08 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a44efd4 > )(7/16) > switched to CANCELED > 03/10/2015 13:44:08 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a44efd4 > )(8/16) > switched to CANCELED > 03/10/2015 13:44:08 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a44efd4 > )(9/16) > switched to CANCELED > 03/10/2015 13:44:08 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a44efd4 > )(10/16) > switched to CANCELED > 03/10/2015 13:44:08 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a44efd4 > )(11/16) > switched to CANCELED > 03/10/2015 13:44:08 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a44efd4 > )(12/16) > switched to CANCELED > 03/10/2015 13:44:08 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a44efd4 > )(13/16) > switched to CANCELED > 03/10/2015 13:44:08 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a44efd4 > )(14/16) > switched to CANCELED > 03/10/2015 13:44:08 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a44efd4 > )(15/16) > switched to CANCELED > 03/10/2015 13:44:08 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a44efd4 > )(16/16) > switched to CANCELED > 03/10/2015 13:44:08 CoGroup (CoGroup at > outDegrees(Graph.java:625))(11/16) switched to CANCELED > 03/10/2015 13:44:08 CoGroup (CoGroup at > inDegrees(Graph.java:655))(11/16) switched to CANCELED > 03/10/2015 13:44:08 CoGroup (CoGroup at > inDegrees(Graph.java:655))(10/16) switched to CANCELED > 03/10/2015 13:44:08 CoGroup (CoGroup at > inDegrees(Graph.java:655))(13/16) switched to CANCELED > 03/10/2015 13:44:08 CoGroup (CoGroup at > inDegrees(Graph.java:655))(16/16) switched to CANCELED > 03/10/2015 13:44:08 CoGroup (CoGroup at > inDegrees(Graph.java:655))(7/16) switched to CANCELED > 03/10/2015 13:44:08 CoGroup (CoGroup at > inDegrees(Graph.java:655))(9/16) switched to CANCELED > 03/10/2015 13:44:08 CoGroup (CoGroup at > inDegrees(Graph.java:655))(14/16) switched to CANCELED > 03/10/2015 13:44:08 CoGroup (CoGroup at > inDegrees(Graph.java:655))(8/16) switched to CANCELED > 03/10/2015 13:44:08 CoGroup (CoGroup at > inDegrees(Graph.java:655))(12/16) switched to CANCELED > 03/10/2015 13:44:08 CoGroup (CoGroup at > outDegrees(Graph.java:625))(13/16) switched to CANCELED > 03/10/2015 13:44:08 CoGroup (CoGroup at > outDegrees(Graph.java:625))(7/16) switched to CANCELED > 03/10/2015 13:44:08 CoGroup (CoGroup at > inDegrees(Graph.java:655))(3/16) switched to CANCELED > 03/10/2015 13:44:08 CoGroup (CoGroup at > outDegrees(Graph.java:625))(1/16) switched to CANCELED > 03/10/2015 13:44:08 CoGroup (CoGroup at > outDegrees(Graph.java:625))(2/16) switched to CANCELED > 03/10/2015 13:44:08 CoGroup (CoGroup at > outDegrees(Graph.java:625))(3/16) switched to CANCELED > 03/10/2015 13:44:08 CoGroup (CoGroup at > outDegrees(Graph.java:625))(4/16) switched to CANCELED > 03/10/2015 13:44:08 CoGroup (CoGroup at > inDegrees(Graph.java:655))(5/16) switched to CANCELED > 03/10/2015 13:44:08 CoGroup (CoGroup at > outDegrees(Graph.java:625))(14/16) switched to CANCELED > 03/10/2015 13:44:08 CoGroup (CoGroup at > inDegrees(Graph.java:655))(15/16) switched to CANCELED > 03/10/2015 13:44:08 CoGroup (CoGroup at > outDegrees(Graph.java:625))(12/16) switched to CANCELED > 03/10/2015 13:44:08 CoGroup (CoGroup at > outDegrees(Graph.java:625))(5/16) switched to CANCELED > 03/10/2015 13:44:08 CoGroup (CoGroup at > inDegrees(Graph.java:655))(6/16) switched to CANCELED > 03/10/2015 13:44:08 Reduce(SUM(1), at getDegrees(Graph.java:664)(1/16) > switched to CANCELED > 03/10/2015 13:44:08 Reduce(SUM(1), at getDegrees(Graph.java:664)(2/16) > switched to CANCELED > 03/10/2015 13:44:08 Reduce(SUM(1), at > getDegrees(Graph.java:664)(15/16) switched to CANCELED > 03/10/2015 13:44:08 Reduce(SUM(1), at > getDegrees(Graph.java:664)(16/16) switched to CANCELED > 03/10/2015 13:44:08 Reduce(SUM(1), at getDegrees(Graph.java:664)(3/16) > switched to CANCELED > 03/10/2015 13:44:08 Reduce(SUM(1), at > getDegrees(Graph.java:664)(14/16) switched to CANCELED > 03/10/2015 13:44:08 Reduce(SUM(1), at > getDegrees(Graph.java:664)(13/16) switched to CANCELED > 03/10/2015 13:44:08 Reduce(SUM(1), at > getDegrees(Graph.java:664)(12/16) switched to CANCELED > 03/10/2015 13:44:08 Reduce(SUM(1), at > getDegrees(Graph.java:664)(11/16) switched to CANCELED > 03/10/2015 13:44:08 Reduce(SUM(1), at getDegrees(Graph.java:664)(9/16) > switched to CANCELED > 03/10/2015 13:44:08 Reduce(SUM(1), at > getDegrees(Graph.java:664)(10/16) switched to CANCELED > 03/10/2015 13:44:08 Reduce(SUM(1), at getDegrees(Graph.java:664)(8/16) > switched to CANCELED > 03/10/2015 13:44:08 Reduce(SUM(1), at getDegrees(Graph.java:664)(5/16) > switched to CANCELED > 03/10/2015 13:44:08 Reduce(SUM(1), at getDegrees(Graph.java:664)(4/16) > switched to CANCELED > 03/10/2015 13:44:08 Reduce(SUM(1), at getDegrees(Graph.java:664)(7/16) > switched to CANCELED > 03/10/2015 13:44:08 Reduce(SUM(1), at getDegrees(Graph.java:664)(6/16) > switched to CANCELED > 03/10/2015 13:44:08 Job execution switched to status FAILED. > 03/10/2015 13:44:09 Job execution switched to status RUNNING. > 03/10/2015 13:44:09 DataSource (at > getLongLongVertexData(TestGraphUtils.java:37) > (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to > SCHEDULED > 03/10/2015 13:44:09 DataSource (at > getLongLongVertexData(TestGraphUtils.java:37) > (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to > DEPLOYING > 03/10/2015 13:44:09 DataSource (at > getLongLongEdgeInvalidTrgData(TestGraphUtils.java:63) > (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to > SCHEDULED > 03/10/2015 13:44:09 DataSource (at > getLongLongEdgeInvalidTrgData(TestGraphUtils.java:63) > (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to > DEPLOYING > 03/10/2015 13:44:09 DataSource (at > getLongLongVertexData(TestGraphUtils.java:37) > (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to > RUNNING > 03/10/2015 13:44:09 DataSource (at > getLongLongEdgeInvalidTrgData(TestGraphUtils.java:63) > (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to > RUNNING > 03/10/2015 13:44:09 CoGroup (CoGroup at > outDegrees(Graph.java:625))(1/16) switched to SCHEDULED > 03/10/2015 13:44:09 CoGroup (CoGroup at > outDegrees(Graph.java:625))(1/16) switched to DEPLOYING > 03/10/2015 13:44:09 CoGroup (CoGroup at > outDegrees(Graph.java:625))(2/16) switched to SCHEDULED > 03/10/2015 13:44:09 CoGroup (CoGroup at > outDegrees(Graph.java:625))(3/16) switched to SCHEDULED > 03/10/2015 13:44:09 CoGroup (CoGroup at > outDegrees(Graph.java:625))(2/16) switched to DEPLOYING > 03/10/2015 13:44:09 CoGroup (CoGroup at > outDegrees(Graph.java:625))(3/16) switched to DEPLOYING > 03/10/2015 13:44:09 CoGroup (CoGroup at > outDegrees(Graph.java:625))(4/16) switched to SCHEDULED > 03/10/2015 13:44:09 CoGroup (CoGroup at > outDegrees(Graph.java:625))(5/16) switched to SCHEDULED > 03/10/2015 13:44:09 CoGroup (CoGroup at > outDegrees(Graph.java:625))(4/16) switched to DEPLOYING > 03/10/2015 13:44:09 CoGroup (CoGroup at > outDegrees(Graph.java:625))(5/16) switched to DEPLOYING > 03/10/2015 13:44:09 CoGroup (CoGroup at > outDegrees(Graph.java:625))(6/16) switched to SCHEDULED > 03/10/2015 13:44:09 CoGroup (CoGroup at > outDegrees(Graph.java:625))(7/16) switched to SCHEDULED > 03/10/2015 13:44:09 CoGroup (CoGroup at > outDegrees(Graph.java:625))(6/16) switched to DEPLOYING > 03/10/2015 13:44:09 CoGroup (CoGroup at > outDegrees(Graph.java:625))(7/16) switched to DEPLOYING > 03/10/2015 13:44:09 CoGroup (CoGroup at > outDegrees(Graph.java:625))(8/16) switched to SCHEDULED > 03/10/2015 13:44:09 CoGroup (CoGroup at > outDegrees(Graph.java:625))(9/16) switched to SCHEDULED > 03/10/2015 13:44:09 CoGroup (CoGroup at > outDegrees(Graph.java:625))(8/16) switched to DEPLOYING > 03/10/2015 13:44:09 CoGroup (CoGroup at > outDegrees(Graph.java:625))(9/16) switched to DEPLOYING > 03/10/2015 13:44:09 CoGroup (CoGroup at > outDegrees(Graph.java:625))(10/16) switched to SCHEDULED > 03/10/2015 13:44:09 CoGroup (CoGroup at > outDegrees(Graph.java:625))(11/16) switched to SCHEDULED > 03/10/2015 13:44:09 CoGroup (CoGroup at > outDegrees(Graph.java:625))(10/16) switched to DEPLOYING > 03/10/2015 13:44:09 CoGroup (CoGroup at > outDegrees(Graph.java:625))(11/16) switched to DEPLOYING > 03/10/2015 13:44:09 CoGroup (CoGroup at > outDegrees(Graph.java:625))(12/16) switched to SCHEDULED > 03/10/2015 13:44:09 CoGroup (CoGroup at > outDegrees(Graph.java:625))(13/16) switched to SCHEDULED > 03/10/2015 13:44:09 CoGroup (CoGroup at > outDegrees(Graph.java:625))(12/16) switched to DEPLOYING > 03/10/2015 13:44:09 CoGroup (CoGroup at > outDegrees(Graph.java:625))(13/16) switched to DEPLOYING > 03/10/2015 13:44:09 CoGroup (CoGroup at > outDegrees(Graph.java:625))(14/16) switched to SCHEDULED > 03/10/2015 13:44:09 CoGroup (CoGroup at > outDegrees(Graph.java:625))(15/16) switched to SCHEDULED > 03/10/2015 13:44:09 CoGroup (CoGroup at > outDegrees(Graph.java:625))(14/16) switched to DEPLOYING > 03/10/2015 13:44:09 CoGroup (CoGroup at > outDegrees(Graph.java:625))(15/16) switched to DEPLOYING > 03/10/2015 13:44:09 CoGroup (CoGroup at > outDegrees(Graph.java:625))(16/16) switched to SCHEDULED > 03/10/2015 13:44:09 CoGroup (CoGroup at > inDegrees(Graph.java:655))(1/16) switched to SCHEDULED > 03/10/2015 13:44:09 CoGroup (CoGroup at > outDegrees(Graph.java:625))(16/16) switched to DEPLOYING > 03/10/2015 13:44:09 CoGroup (CoGroup at > inDegrees(Graph.java:655))(1/16) switched to DEPLOYING > 03/10/2015 13:44:09 CoGroup (CoGroup at > inDegrees(Graph.java:655))(2/16) switched to SCHEDULED > 03/10/2015 13:44:09 CoGroup (CoGroup at > inDegrees(Graph.java:655))(3/16) switched to SCHEDULED > 03/10/2015 13:44:09 CoGroup (CoGroup at > inDegrees(Graph.java:655))(2/16) switched to DEPLOYING > 03/10/2015 13:44:09 CoGroup (CoGroup at > inDegrees(Graph.java:655))(3/16) switched to DEPLOYING > 03/10/2015 13:44:09 CoGroup (CoGroup at > inDegrees(Graph.java:655))(4/16) switched to SCHEDULED > 03/10/2015 13:44:09 CoGroup (CoGroup at > inDegrees(Graph.java:655))(5/16) switched to SCHEDULED > 03/10/2015 13:44:09 CoGroup (CoGroup at > inDegrees(Graph.java:655))(4/16) switched to DEPLOYING > 03/10/2015 13:44:09 CoGroup (CoGroup at > inDegrees(Graph.java:655))(5/16) switched to DEPLOYING > 03/10/2015 13:44:09 CoGroup (CoGroup at > inDegrees(Graph.java:655))(6/16) switched to SCHEDULED > 03/10/2015 13:44:09 CoGroup (CoGroup at > inDegrees(Graph.java:655))(7/16) switched to SCHEDULED > 03/10/2015 13:44:09 CoGroup (CoGroup at > inDegrees(Graph.java:655))(6/16) switched to DEPLOYING > 03/10/2015 13:44:09 CoGroup (CoGroup at > inDegrees(Graph.java:655))(7/16) switched to DEPLOYING > 03/10/2015 13:44:09 CoGroup (CoGroup at > inDegrees(Graph.java:655))(8/16) switched to SCHEDULED > 03/10/2015 13:44:09 CoGroup (CoGroup at > inDegrees(Graph.java:655))(9/16) switched to SCHEDULED > 03/10/2015 13:44:09 CoGroup (CoGroup at > inDegrees(Graph.java:655))(8/16) switched to DEPLOYING > 03/10/2015 13:44:09 CoGroup (CoGroup at > inDegrees(Graph.java:655))(9/16) switched to DEPLOYING > 03/10/2015 13:44:09 CoGroup (CoGroup at > inDegrees(Graph.java:655))(10/16) switched to SCHEDULED > 03/10/2015 13:44:09 CoGroup (CoGroup at > inDegrees(Graph.java:655))(11/16) switched to SCHEDULED > 03/10/2015 13:44:09 CoGroup (CoGroup at > inDegrees(Graph.java:655))(10/16) switched to DEPLOYING > 03/10/2015 13:44:09 CoGroup (CoGroup at > inDegrees(Graph.java:655))(11/16) switched to DEPLOYING > 03/10/2015 13:44:09 CoGroup (CoGroup at > inDegrees(Graph.java:655))(12/16) switched to SCHEDULED > 03/10/2015 13:44:09 CoGroup (CoGroup at > inDegrees(Graph.java:655))(13/16) switched to SCHEDULED > 03/10/2015 13:44:09 CoGroup (CoGroup at > inDegrees(Graph.java:655))(12/16) switched to DEPLOYING > 03/10/2015 13:44:09 CoGroup (CoGroup at > inDegrees(Graph.java:655))(13/16) switched to DEPLOYING > 03/10/2015 13:44:09 CoGroup (CoGroup at > inDegrees(Graph.java:655))(14/16) switched to SCHEDULED > 03/10/2015 13:44:09 CoGroup (CoGroup at > inDegrees(Graph.java:655))(15/16) switched to SCHEDULED > 03/10/2015 13:44:09 CoGroup (CoGroup at > inDegrees(Graph.java:655))(14/16) switched to DEPLOYING > 03/10/2015 13:44:09 CoGroup (CoGroup at > inDegrees(Graph.java:655))(15/16) switched to DEPLOYING > 03/10/2015 13:44:09 CoGroup (CoGroup at > inDegrees(Graph.java:655))(16/16) switched to SCHEDULED > 03/10/2015 13:44:09 CoGroup (CoGroup at > inDegrees(Graph.java:655))(16/16) switched to DEPLOYING > 03/10/2015 13:44:09 DataSource (at > getLongLongEdgeInvalidTrgData(TestGraphUtils.java:63) > (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to > FINISHED > 03/10/2015 13:44:09 CoGroup (CoGroup at > outDegrees(Graph.java:625))(1/16) switched to RUNNING > 03/10/2015 13:44:09 CoGroup (CoGroup at > outDegrees(Graph.java:625))(2/16) switched to RUNNING > 03/10/2015 13:44:09 CoGroup (CoGroup at > outDegrees(Graph.java:625))(3/16) switched to RUNNING > 03/10/2015 13:44:09 CoGroup (CoGroup at > outDegrees(Graph.java:625))(4/16) switched to RUNNING > 03/10/2015 13:44:09 CoGroup (CoGroup at > outDegrees(Graph.java:625))(5/16) switched to RUNNING > 03/10/2015 13:44:09 CoGroup (CoGroup at > outDegrees(Graph.java:625))(6/16) switched to RUNNING > 03/10/2015 13:44:09 CoGroup (CoGroup at > outDegrees(Graph.java:625))(7/16) switched to RUNNING > 03/10/2015 13:44:09 CoGroup (CoGroup at > outDegrees(Graph.java:625))(8/16) switched to RUNNING > 03/10/2015 13:44:09 CoGroup (CoGroup at > outDegrees(Graph.java:625))(9/16) switched to RUNNING > 03/10/2015 13:44:09 CoGroup (CoGroup at > outDegrees(Graph.java:625))(10/16) switched to RUNNING > 03/10/2015 13:44:09 CoGroup (CoGroup at > outDegrees(Graph.java:625))(11/16) switched to RUNNING > 03/10/2015 13:44:09 CoGroup (CoGroup at > outDegrees(Graph.java:625))(12/16) switched to RUNNING > 03/10/2015 13:44:09 CoGroup (CoGroup at > outDegrees(Graph.java:625))(13/16) switched to RUNNING > 03/10/2015 13:44:09 CoGroup (CoGroup at > outDegrees(Graph.java:625))(14/16) switched to RUNNING > 03/10/2015 13:44:09 CoGroup (CoGroup at > outDegrees(Graph.java:625))(15/16) switched to RUNNING > 03/10/2015 13:44:09 CoGroup (CoGroup at > outDegrees(Graph.java:625))(16/16) switched to RUNNING > 03/10/2015 13:44:09 CoGroup (CoGroup at > inDegrees(Graph.java:655))(1/16) switched to RUNNING > 03/10/2015 13:44:09 CoGroup (CoGroup at > inDegrees(Graph.java:655))(2/16) switched to RUNNING > 03/10/2015 13:44:09 CoGroup (CoGroup at > inDegrees(Graph.java:655))(3/16) switched to RUNNING > 03/10/2015 13:44:09 CoGroup (CoGroup at > inDegrees(Graph.java:655))(4/16) switched to RUNNING > 03/10/2015 13:44:09 CoGroup (CoGroup at > inDegrees(Graph.java:655))(5/16) switched to RUNNING > 03/10/2015 13:44:09 CoGroup (CoGroup at > inDegrees(Graph.java:655))(6/16) switched to RUNNING > 03/10/2015 13:44:09 CoGroup (CoGroup at > inDegrees(Graph.java:655))(7/16) switched to RUNNING > 03/10/2015 13:44:09 CoGroup (CoGroup at > inDegrees(Graph.java:655))(8/16) switched to RUNNING > 03/10/2015 13:44:09 CoGroup (CoGroup at > inDegrees(Graph.java:655))(9/16) switched to RUNNING > 03/10/2015 13:44:09 CoGroup (CoGroup at > inDegrees(Graph.java:655))(10/16) switched to RUNNING > 03/10/2015 13:44:09 CoGroup (CoGroup at > inDegrees(Graph.java:655))(11/16) switched to RUNNING > 03/10/2015 13:44:09 CoGroup (CoGroup at > inDegrees(Graph.java:655))(12/16) switched to RUNNING > 03/10/2015 13:44:09 CoGroup (CoGroup at > inDegrees(Graph.java:655))(13/16) switched to RUNNING > 03/10/2015 13:44:09 CoGroup (CoGroup at > inDegrees(Graph.java:655))(15/16) switched to RUNNING > 03/10/2015 13:44:09 CoGroup (CoGroup at > inDegrees(Graph.java:655))(16/16) switched to RUNNING > 03/10/2015 13:44:10 Reduce(SUM(1), at getDegrees(Graph.java:664)(1/16) > switched to SCHEDULED > 03/10/2015 13:44:10 Reduce(SUM(1), at getDegrees(Graph.java:664)(1/16) > switched to DEPLOYING > 03/10/2015 13:44:10 Reduce(SUM(1), at getDegrees(Graph.java:664)(2/16) > switched to SCHEDULED > 03/10/2015 13:44:10 Reduce(SUM(1), at getDegrees(Graph.java:664)(2/16) > switched to DEPLOYING > 03/10/2015 13:44:10 Reduce(SUM(1), at getDegrees(Graph.java:664)(3/16) > switched to SCHEDULED > 03/10/2015 13:44:10 Reduce(SUM(1), at getDegrees(Graph.java:664)(3/16) > switched to DEPLOYING > 03/10/2015 13:44:10 Reduce(SUM(1), at getDegrees(Graph.java:664)(4/16) > switched to SCHEDULED > 03/10/2015 13:44:10 Reduce(SUM(1), at getDegrees(Graph.java:664)(4/16) > switched to DEPLOYING > 03/10/2015 13:44:10 Reduce(SUM(1), at getDegrees(Graph.java:664)(5/16) > switched to SCHEDULED > 03/10/2015 13:44:10 Reduce(SUM(1), at getDegrees(Graph.java:664)(6/16) > switched to SCHEDULED > 03/10/2015 13:44:10 Reduce(SUM(1), at getDegrees(Graph.java:664)(5/16) > switched to DEPLOYING > 03/10/2015 13:44:10 Reduce(SUM(1), at getDegrees(Graph.java:664)(6/16) > switched to DEPLOYING > 03/10/2015 13:44:10 Reduce(SUM(1), at getDegrees(Graph.java:664)(7/16) > switched to SCHEDULED > 03/10/2015 13:44:10 Reduce(SUM(1), at getDegrees(Graph.java:664)(7/16) > switched to DEPLOYING > 03/10/2015 13:44:10 Reduce(SUM(1), at getDegrees(Graph.java:664)(8/16) > switched to SCHEDULED > 03/10/2015 13:44:10 Reduce(SUM(1), at getDegrees(Graph.java:664)(9/16) > switched to SCHEDULED > 03/10/2015 13:44:10 Reduce(SUM(1), at getDegrees(Graph.java:664)(8/16) > switched to DEPLOYING > 03/10/2015 13:44:10 Reduce(SUM(1), at getDegrees(Graph.java:664)(9/16) > switched to DEPLOYING > 03/10/2015 13:44:10 Reduce(SUM(1), at > getDegrees(Graph.java:664)(10/16) switched to SCHEDULED > 03/10/2015 13:44:10 Reduce(SUM(1), at > getDegrees(Graph.java:664)(10/16) switched to DEPLOYING > 03/10/2015 13:44:10 Reduce(SUM(1), at > getDegrees(Graph.java:664)(11/16) switched to SCHEDULED > 03/10/2015 13:44:10 Reduce(SUM(1), at > getDegrees(Graph.java:664)(12/16) switched to SCHEDULED > 03/10/2015 13:44:10 Reduce(SUM(1), at > getDegrees(Graph.java:664)(11/16) switched to DEPLOYING > 03/10/2015 13:44:10 Reduce(SUM(1), at > getDegrees(Graph.java:664)(12/16) switched to DEPLOYING > 03/10/2015 13:44:10 Reduce(SUM(1), at > getDegrees(Graph.java:664)(13/16) switched to SCHEDULED > 03/10/2015 13:44:10 Reduce(SUM(1), at > getDegrees(Graph.java:664)(13/16) switched to DEPLOYING > 03/10/2015 13:44:10 Reduce(SUM(1), at > getDegrees(Graph.java:664)(14/16) switched to SCHEDULED > 03/10/2015 13:44:10 Reduce(SUM(1), at > getDegrees(Graph.java:664)(14/16) switched to DEPLOYING > 03/10/2015 13:44:10 Reduce(SUM(1), at > getDegrees(Graph.java:664)(15/16) switched to SCHEDULED > 03/10/2015 13:44:10 Reduce(SUM(1), at > getDegrees(Graph.java:664)(15/16) switched to DEPLOYING > 03/10/2015 13:44:10 Reduce(SUM(1), at > getDegrees(Graph.java:664)(16/16) switched to SCHEDULED > 03/10/2015 13:44:10 Reduce(SUM(1), at > getDegrees(Graph.java:664)(16/16) switched to DEPLOYING > 03/10/2015 13:44:10 CoGroup (CoGroup at > inDegrees(Graph.java:655))(14/16) switched to RUNNING > 03/10/2015 13:44:10 Reduce(SUM(1), at getDegrees(Graph.java:664)(1/16) > switched to RUNNING > 03/10/2015 13:44:10 Reduce(SUM(1), at getDegrees(Graph.java:664)(2/16) > switched to RUNNING > 03/10/2015 13:44:10 Reduce(SUM(1), at getDegrees(Graph.java:664)(3/16) > switched to RUNNING > 03/10/2015 13:44:10 Reduce(SUM(1), at getDegrees(Graph.java:664)(4/16) > switched to RUNNING > 03/10/2015 13:44:10 Reduce(SUM(1), at getDegrees(Graph.java:664)(5/16) > switched to RUNNING > 03/10/2015 13:44:10 Reduce(SUM(1), at getDegrees(Graph.java:664)(7/16) > switched to RUNNING > 03/10/2015 13:44:10 Reduce(SUM(1), at getDegrees(Graph.java:664)(8/16) > switched to RUNNING > 03/10/2015 13:44:10 Reduce(SUM(1), at > getDegrees(Graph.java:664)(10/16) switched to RUNNING > 03/10/2015 13:44:10 Reduce(SUM(1), at > getDegrees(Graph.java:664)(11/16) switched to RUNNING > 03/10/2015 13:44:10 Reduce(SUM(1), at > getDegrees(Graph.java:664)(13/16) switched to RUNNING > 03/10/2015 13:44:10 Reduce(SUM(1), at > getDegrees(Graph.java:664)(14/16) switched to RUNNING > 03/10/2015 13:44:10 Reduce(SUM(1), at > getDegrees(Graph.java:664)(15/16) switched to RUNNING > 03/10/2015 13:44:10 Reduce(SUM(1), at > getDegrees(Graph.java:664)(16/16) switched to RUNNING > 03/10/2015 13:44:10 Reduce(SUM(1), at getDegrees(Graph.java:664)(6/16) > switched to RUNNING > 03/10/2015 13:44:10 Reduce(SUM(1), at > getDegrees(Graph.java:664)(12/16) switched to RUNNING > 03/10/2015 13:44:10 Reduce(SUM(1), at getDegrees(Graph.java:664)(9/16) > switched to RUNNING > 03/10/2015 13:44:10 DataSource (at > getLongLongVertexData(TestGraphUtils.java:37) > (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to > FINISHED > 03/10/2015 13:44:10 CoGroup (CoGroup at > inDegrees(Graph.java:655))(10/16) switched to FINISHED > 03/10/2015 13:44:10 CoGroup (CoGroup at > inDegrees(Graph.java:655))(8/16) switched to FINISHED > 03/10/2015 13:44:10 CoGroup (CoGroup at > inDegrees(Graph.java:655))(7/16) switched to FINISHED > 03/10/2015 13:44:10 CoGroup (CoGroup at > inDegrees(Graph.java:655))(5/16) switched to FINISHED > 03/10/2015 13:44:10 CoGroup (CoGroup at > inDegrees(Graph.java:655))(2/16) switched to FINISHED > 03/10/2015 13:44:10 CoGroup (CoGroup at > inDegrees(Graph.java:655))(3/16) switched to FINISHED > 03/10/2015 13:44:10 CoGroup (CoGroup at > inDegrees(Graph.java:655))(1/16) switched to FINISHED > 03/10/2015 13:44:10 CoGroup (CoGroup at > outDegrees(Graph.java:625))(16/16) switched to FINISHED > 03/10/2015 13:44:10 CoGroup (CoGroup at > outDegrees(Graph.java:625))(15/16) switched to FINISHED > 03/10/2015 13:44:10 CoGroup (CoGroup at > outDegrees(Graph.java:625))(13/16) switched to FINISHED > 03/10/2015 13:44:10 CoGroup (CoGroup at > outDegrees(Graph.java:625))(10/16) switched to FINISHED > 03/10/2015 13:44:10 CoGroup (CoGroup at > outDegrees(Graph.java:625))(7/16) switched to FINISHED > 03/10/2015 13:44:10 CoGroup (CoGroup at > outDegrees(Graph.java:625))(3/16) switched to FINISHED > 03/10/2015 13:44:10 CoGroup (CoGroup at > outDegrees(Graph.java:625))(4/16) switched to FINISHED > 03/10/2015 13:44:10 CoGroup (CoGroup at > outDegrees(Graph.java:625))(2/16) switched to FINISHED > 03/10/2015 13:44:10 CoGroup (CoGroup at > inDegrees(Graph.java:655))(11/16) switched to FINISHED > 03/10/2015 13:44:10 CoGroup (CoGroup at > inDegrees(Graph.java:655))(6/16) switched to FINISHED > 03/10/2015 13:44:10 CoGroup (CoGroup at > inDegrees(Graph.java:655))(16/16) switched to FINISHED > 03/10/2015 13:44:10 CoGroup (CoGroup at > outDegrees(Graph.java:625))(1/16) switched to FINISHED > 03/10/2015 13:44:10 CoGroup (CoGroup at > outDegrees(Graph.java:625))(5/16) switched to FINISHED > 03/10/2015 13:44:10 CoGroup (CoGroup at > outDegrees(Graph.java:625))(8/16) switched to FINISHED > 03/10/2015 13:44:10 CoGroup (CoGroup at > outDegrees(Graph.java:625))(12/16) switched to FINISHED > 03/10/2015 13:44:10 CoGroup (CoGroup at > outDegrees(Graph.java:625))(14/16) switched to FINISHED > 03/10/2015 13:44:10 CoGroup (CoGroup at > inDegrees(Graph.java:655))(13/16) switched to FINISHED > 03/10/2015 13:44:10 CoGroup (CoGroup at > outDegrees(Graph.java:625))(9/16) switched to FINISHED > 03/10/2015 13:44:10 CoGroup (CoGroup at > outDegrees(Graph.java:625))(11/16) switched to FINISHED > 03/10/2015 13:44:10 CoGroup (CoGroup at > outDegrees(Graph.java:625))(6/16) switched to FINISHED > 03/10/2015 13:44:10 CoGroup (CoGroup at > inDegrees(Graph.java:655))(12/16) switched to FINISHED > 03/10/2015 13:44:10 CoGroup (CoGroup at > inDegrees(Graph.java:655))(4/16) switched to FINISHED > 03/10/2015 13:44:10 CoGroup (CoGroup at > inDegrees(Graph.java:655))(9/16) switched to FAILED > java.util.NoSuchElementException: The edge src/trg id could not be > found within the vertexIds > at > org.apache.flink.graph.Graph$CountNeighborsCoGroup.coGroup(Graph.java:643) > at > org.apache.flink.runtime.operators.CoGroupDriver.run(CoGroupDriver.java:152) > at > org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:496) > at > org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:362) > at > org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:205) > at java.lang.Thread.run(Thread.java:701) > > 03/10/2015 13:44:10 Job execution switched to status FAILING. > 03/10/2015 13:44:10 CoGroup (CoGroup at > inDegrees(Graph.java:655))(14/16) switched to CANCELING > 03/10/2015 13:44:10 CoGroup (CoGroup at > inDegrees(Graph.java:655))(15/16) switched to CANCELING > 03/10/2015 13:44:10 Reduce(SUM(1), at getDegrees(Graph.java:664)(1/16) > switched to CANCELING > 03/10/2015 13:44:10 Reduce(SUM(1), at getDegrees(Graph.java:664)(2/16) > switched to CANCELING > 03/10/2015 13:44:10 Reduce(SUM(1), at getDegrees(Graph.java:664)(3/16) > switched to CANCELING > 03/10/2015 13:44:10 Reduce(SUM(1), at getDegrees(Graph.java:664)(4/16) > switched to CANCELING > 03/10/2015 13:44:10 Reduce(SUM(1), at getDegrees(Graph.java:664)(5/16) > switched to CANCELING > 03/10/2015 13:44:10 Reduce(SUM(1), at getDegrees(Graph.java:664)(6/16) > switched to CANCELING > 03/10/2015 13:44:10 Reduce(SUM(1), at getDegrees(Graph.java:664)(7/16) > switched to CANCELING > 03/10/2015 13:44:10 Reduce(SUM(1), at getDegrees(Graph.java:664)(8/16) > switched to CANCELING > 03/10/2015 13:44:10 Reduce(SUM(1), at getDegrees(Graph.java:664)(9/16) > switched to CANCELING > 03/10/2015 13:44:10 Reduce(SUM(1), at > getDegrees(Graph.java:664)(10/16) switched to CANCELING > 03/10/2015 13:44:10 Reduce(SUM(1), at > getDegrees(Graph.java:664)(11/16) switched to CANCELING > 03/10/2015 13:44:10 Reduce(SUM(1), at > getDegrees(Graph.java:664)(12/16) switched to CANCELING > 03/10/2015 13:44:10 Reduce(SUM(1), at > getDegrees(Graph.java:664)(13/16) switched to CANCELING > 03/10/2015 13:44:10 Reduce(SUM(1), at > getDegrees(Graph.java:664)(14/16) switched to CANCELING > 03/10/2015 13:44:10 Reduce(SUM(1), at > getDegrees(Graph.java:664)(15/16) switched to CANCELING > 03/10/2015 13:44:10 Reduce(SUM(1), at > getDegrees(Graph.java:664)(16/16) switched to CANCELING > 03/10/2015 13:44:10 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a6d476 > )(1/16) > switched to CANCELED > 03/10/2015 13:44:10 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a6d476 > )(2/16) > switched to CANCELED > 03/10/2015 13:44:10 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a6d476 > )(3/16) > switched to CANCELED > 03/10/2015 13:44:10 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a6d476 > )(4/16) > switched to CANCELED > 03/10/2015 13:44:10 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a6d476 > )(5/16) > switched to CANCELED > 03/10/2015 13:44:10 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a6d476 > )(6/16) > switched to CANCELED > 03/10/2015 13:44:10 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a6d476 > )(7/16) > switched to CANCELED > 03/10/2015 13:44:10 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a6d476 > )(8/16) > switched to CANCELED > 03/10/2015 13:44:10 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a6d476 > )(9/16) > switched to CANCELED > 03/10/2015 13:44:10 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a6d476 > )(10/16) > switched to CANCELED > 03/10/2015 13:44:10 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a6d476 > )(11/16) > switched to CANCELED > 03/10/2015 13:44:10 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a6d476 > )(12/16) > switched to CANCELED > 03/10/2015 13:44:10 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a6d476 > )(13/16) > switched to CANCELED > 03/10/2015 13:44:10 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a6d476 > )(14/16) > switched to CANCELED > 03/10/2015 13:44:10 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a6d476 > )(15/16) > switched to CANCELED > 03/10/2015 13:44:10 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@5a6d476 > )(16/16) > switched to CANCELED > 03/10/2015 13:44:10 CoGroup (CoGroup at > inDegrees(Graph.java:655))(14/16) switched to CANCELED > 03/10/2015 13:44:10 CoGroup (CoGroup at > inDegrees(Graph.java:655))(15/16) switched to CANCELED > 03/10/2015 13:44:10 Reduce(SUM(1), at getDegrees(Graph.java:664)(7/16) > switched to CANCELED > 03/10/2015 13:44:10 Reduce(SUM(1), at > getDegrees(Graph.java:664)(11/16) switched to FAILED > java.lang.Exception: The data preparation for task 'Reduce(SUM(1), at > getDegrees(Graph.java:664)' , caused an error: Error obtaining the > sorted input: Thread 'SortMerger Reading Thread' terminated due to an > exception: Bug in input gate/channel logic: input gate gotnotified by > channel about available data, but none was available. > at > org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:471) > at > org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:362) > at > org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:205) > at java.lang.Thread.run(Thread.java:701) > Caused by: java.lang.RuntimeException: Error obtaining the sorted > input: Thread 'SortMerger Reading Thread' terminated due to an > exception: Bug in input gate/channel logic: input gate gotnotified by > channel about available data, but none was available. > at > org.apache.flink.runtime.operators.sort.UnilateralSortMerger.getIterator(UnilateralSortMerger.java:607) > at > org.apache.flink.runtime.operators.RegularPactTask.getInput(RegularPactTask.java:1131) > at > org.apache.flink.runtime.operators.GroupReduceDriver.prepare(GroupReduceDriver.java:94) > at > org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:466) > ... 3 more > Caused by: java.io.IOException: Thread 'SortMerger Reading Thread' > terminated due to an exception: Bug in input gate/channel logic: input > gate gotnotified by channel about available data, but none was > available. > at > org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:784) > Caused by: java.lang.IllegalStateException: Bug in input gate/channel > logic: input gate gotnotified by channel about available data, but > none was available. > at > org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.getNextBufferOrEvent(SingleInputGate.java:314) > at > org.apache.flink.runtime.io.network.partition.consumer.UnionInputGate.getNextBufferOrEvent(UnionInputGate.java:141) > at > org.apache.flink.runtime.io.network.api.reader.AbstractRecordReader.getNextRecord(AbstractRecordReader.java:75) > at > org.apache.flink.runtime.io.network.api.reader.MutableRecordReader.next(MutableRecordReader.java:34) > at > org.apache.flink.runtime.operators.util.ReaderIterator.next(ReaderIterator.java:59) > at > org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ReadingThread.go(UnilateralSortMerger.java:958) > at > org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:781) > > 03/10/2015 13:44:10 Reduce(SUM(1), at > getDegrees(Graph.java:664)(12/16) switched to FAILED > java.lang.Exception: The data preparation for task 'Reduce(SUM(1), at > getDegrees(Graph.java:664)' , caused an error: Error obtaining the > sorted input: Thread 'SortMerger Reading Thread' terminated due to an > exception: Bug in input gate/channel logic: input gate gotnotified by > channel about available data, but none was available. > at > org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:471) > at > org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:362) > at > org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:205) > at java.lang.Thread.run(Thread.java:701) > Caused by: java.lang.RuntimeException: Error obtaining the sorted > input: Thread 'SortMerger Reading Thread' terminated due to an > exception: Bug in input gate/channel logic: input gate gotnotified by > channel about available data, but none was available. > at > org.apache.flink.runtime.operators.sort.UnilateralSortMerger.getIterator(UnilateralSortMerger.java:607) > at > org.apache.flink.runtime.operators.RegularPactTask.getInput(RegularPactTask.java:1131) > at > org.apache.flink.runtime.operators.GroupReduceDriver.prepare(GroupReduceDriver.java:94) > at > org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:466) > ... 3 more > Caused by: java.io.IOException: Thread 'SortMerger Reading Thread' > terminated due to an exception: Bug in input gate/channel logic: input > gate gotnotified by channel about available data, but none was > available. > at > org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:784) > Caused by: java.lang.IllegalStateException: Bug in input gate/channel > logic: input gate gotnotified by channel about available data, but > none was available. > at > org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.getNextBufferOrEvent(SingleInputGate.java:314) > at > org.apache.flink.runtime.io.network.partition.consumer.UnionInputGate.getNextBufferOrEvent(UnionInputGate.java:141) > at > org.apache.flink.runtime.io.network.api.reader.AbstractRecordReader.getNextRecord(AbstractRecordReader.java:75) > at > org.apache.flink.runtime.io.network.api.reader.MutableRecordReader.next(MutableRecordReader.java:34) > at > org.apache.flink.runtime.operators.util.ReaderIterator.next(ReaderIterator.java:59) > at > org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ReadingThread.go(UnilateralSortMerger.java:958) > at > org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:781) > > 03/10/2015 13:44:10 Reduce(SUM(1), at > getDegrees(Graph.java:664)(10/16) switched to FAILED > java.lang.Exception: The data preparation for task 'Reduce(SUM(1), at > getDegrees(Graph.java:664)' , caused an error: Error obtaining the > sorted input: Thread 'SortMerger Reading Thread' terminated due to an > exception: Bug in input gate/channel logic: input gate gotnotified by > channel about available data, but none was available. > at > org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:471) > at > org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:362) > at > org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:205) > at java.lang.Thread.run(Thread.java:701) > Caused by: java.lang.RuntimeException: Error obtaining the sorted > input: Thread 'SortMerger Reading Thread' terminated due to an > exception: Bug in input gate/channel logic: input gate gotnotified by > channel about available data, but none was available. > at > org.apache.flink.runtime.operators.sort.UnilateralSortMerger.getIterator(UnilateralSortMerger.java:607) > at > org.apache.flink.runtime.operators.RegularPactTask.getInput(RegularPactTask.java:1131) > at > org.apache.flink.runtime.operators.GroupReduceDriver.prepare(GroupReduceDriver.java:94) > at > org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:466) > ... 3 more > Caused by: java.io.IOException: Thread 'SortMerger Reading Thread' > terminated due to an exception: Bug in input gate/channel logic: input > gate gotnotified by channel about available data, but none was > available. > at > org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:784) > Caused by: java.lang.IllegalStateException: Bug in input gate/channel > logic: input gate gotnotified by channel about available data, but > none was available. > at > org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.getNextBufferOrEvent(SingleInputGate.java:314) > at > org.apache.flink.runtime.io.network.partition.consumer.UnionInputGate.getNextBufferOrEvent(UnionInputGate.java:141) > at > org.apache.flink.runtime.io.network.api.reader.AbstractRecordReader.getNextRecord(AbstractRecordReader.java:75) > at > org.apache.flink.runtime.io.network.api.reader.MutableRecordReader.next(MutableRecordReader.java:34) > at > org.apache.flink.runtime.operators.util.ReaderIterator.next(ReaderIterator.java:59) > at > org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ReadingThread.go(UnilateralSortMerger.java:958) > at > org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:781) > > 03/10/2015 13:44:10 Reduce(SUM(1), at getDegrees(Graph.java:664)(9/16) > switched to FAILED > java.lang.Exception: The data preparation for task 'Reduce(SUM(1), at > getDegrees(Graph.java:664)' , caused an error: Error obtaining the > sorted input: Thread 'SortMerger Reading Thread' terminated due to an > exception: Bug in input gate/channel logic: input gate gotnotified by > channel about available data, but none was available. > at > org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:471) > at > org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:362) > at > org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:205) > at java.lang.Thread.run(Thread.java:701) > Caused by: java.lang.RuntimeException: Error obtaining the sorted > input: Thread 'SortMerger Reading Thread' terminated due to an > exception: Bug in input gate/channel logic: input gate gotnotified by > channel about available data, but none was available. > at > org.apache.flink.runtime.operators.sort.UnilateralSortMerger.getIterator(UnilateralSortMerger.java:607) > at > org.apache.flink.runtime.operators.RegularPactTask.getInput(RegularPactTask.java:1131) > at > org.apache.flink.runtime.operators.GroupReduceDriver.prepare(GroupReduceDriver.java:94) > at > org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:466) > ... 3 more > Caused by: java.io.IOException: Thread 'SortMerger Reading Thread' > terminated due to an exception: Bug in input gate/channel logic: input > gate gotnotified by channel about available data, but none was > available. > at > org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:784) > Caused by: java.lang.IllegalStateException: Bug in input gate/channel > logic: input gate gotnotified by channel about available data, but > none was available. > at > org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.getNextBufferOrEvent(SingleInputGate.java:314) > at > org.apache.flink.runtime.io.network.partition.consumer.UnionInputGate.getNextBufferOrEvent(UnionInputGate.java:141) > at > org.apache.flink.runtime.io.network.api.reader.AbstractRecordReader.getNextRecord(AbstractRecordReader.java:75) > at > org.apache.flink.runtime.io.network.api.reader.MutableRecordReader.next(MutableRecordReader.java:34) > at > org.apache.flink.runtime.operators.util.ReaderIterator.next(ReaderIterator.java:59) > at > org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ReadingThread.go(UnilateralSortMerger.java:958) > at > org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:781) > > 03/10/2015 13:44:10 Reduce(SUM(1), at getDegrees(Graph.java:664)(8/16) > switched to FAILED > java.lang.Exception: The data preparation for task 'Reduce(SUM(1), at > getDegrees(Graph.java:664)' , caused an error: Error obtaining the > sorted input: Thread 'SortMerger Reading Thread' terminated due to an > exception: Bug in input gate/channel logic: input gate gotnotified by > channel about available data, but none was available. > at > org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:471) > at > org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:362) > at > org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:205) > at java.lang.Thread.run(Thread.java:701) > Caused by: java.lang.RuntimeException: Error obtaining the sorted > input: Thread 'SortMerger Reading Thread' terminated due to an > exception: Bug in input gate/channel logic: input gate gotnotified by > channel about available data, but none was available. > at > org.apache.flink.runtime.operators.sort.UnilateralSortMerger.getIterator(UnilateralSortMerger.java:607) > at > org.apache.flink.runtime.operators.RegularPactTask.getInput(RegularPactTask.java:1131) > at > org.apache.flink.runtime.operators.GroupReduceDriver.prepare(GroupReduceDriver.java:94) > at > org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:466) > ... 3 more > Caused by: java.io.IOException: Thread 'SortMerger Reading Thread' > terminated due to an exception: Bug in input gate/channel logic: input > gate gotnotified by channel about available data, but none was > available. > at > org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:784) > Caused by: java.lang.IllegalStateException: Bug in input gate/channel > logic: input gate gotnotified by channel about available data, but > none was available. > at > org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.getNextBufferOrEvent(SingleInputGate.java:314) > at > org.apache.flink.runtime.io.network.partition.consumer.UnionInputGate.getNextBufferOrEvent(UnionInputGate.java:141) > at > org.apache.flink.runtime.io.network.api.reader.AbstractRecordReader.getNextRecord(AbstractRecordReader.java:75) > at > org.apache.flink.runtime.io.network.api.reader.MutableRecordReader.next(MutableRecordReader.java:34) > at > org.apache.flink.runtime.operators.util.ReaderIterator.next(ReaderIterator.java:59) > at > org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ReadingThread.go(UnilateralSortMerger.java:958) > at > org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:781) > > 03/10/2015 13:44:10 Reduce(SUM(1), at > getDegrees(Graph.java:664)(13/16) switched to FAILED > java.lang.Exception: The data preparation for task 'Reduce(SUM(1), at > getDegrees(Graph.java:664)' , caused an error: Error obtaining the > sorted input: Thread 'SortMerger Reading Thread' terminated due to an > exception: Bug in input gate/channel logic: input gate gotnotified by > channel about available data, but none was available. > at > org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:471) > at > org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:362) > at > org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:205) > at java.lang.Thread.run(Thread.java:701) > Caused by: java.lang.RuntimeException: Error obtaining the sorted > input: Thread 'SortMerger Reading Thread' terminated due to an > exception: Bug in input gate/channel logic: input gate gotnotified by > channel about available data, but none was available. > at > org.apache.flink.runtime.operators.sort.UnilateralSortMerger.getIterator(UnilateralSortMerger.java:607) > at > org.apache.flink.runtime.operators.RegularPactTask.getInput(RegularPactTask.java:1131) > at > org.apache.flink.runtime.operators.GroupReduceDriver.prepare(GroupReduceDriver.java:94) > at > org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:466) > ... 3 more > Caused by: java.io.IOException: Thread 'SortMerger Reading Thread' > terminated due to an exception: Bug in input gate/channel logic: input > gate gotnotified by channel about available data, but none was > available. > at > org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:784) > Caused by: java.lang.IllegalStateException: Bug in input gate/channel > logic: input gate gotnotified by channel about available data, but > none was available. > at > org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.getNextBufferOrEvent(SingleInputGate.java:314) > at > org.apache.flink.runtime.io.network.partition.consumer.UnionInputGate.getNextBufferOrEvent(UnionInputGate.java:141) > at > org.apache.flink.runtime.io.network.api.reader.AbstractRecordReader.getNextRecord(AbstractRecordReader.java:75) > at > org.apache.flink.runtime.io.network.api.reader.MutableRecordReader.next(MutableRecordReader.java:34) > at > org.apache.flink.runtime.operators.util.ReaderIterator.next(ReaderIterator.java:59) > at > org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ReadingThread.go(UnilateralSortMerger.java:958) > at > org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:781) > > 03/10/2015 13:44:10 Reduce(SUM(1), at getDegrees(Graph.java:664)(6/16) > switched to CANCELED > 03/10/2015 13:44:10 Reduce(SUM(1), at getDegrees(Graph.java:664)(5/16) > switched to CANCELED > 03/10/2015 13:44:10 Reduce(SUM(1), at getDegrees(Graph.java:664)(4/16) > switched to CANCELED > 03/10/2015 13:44:10 Reduce(SUM(1), at getDegrees(Graph.java:664)(3/16) > switched to CANCELED > 03/10/2015 13:44:10 Reduce(SUM(1), at > getDegrees(Graph.java:664)(14/16) switched to FAILED > java.lang.Exception: The data preparation for task 'Reduce(SUM(1), at > getDegrees(Graph.java:664)' , caused an error: Error obtaining the > sorted input: Thread 'SortMerger Reading Thread' terminated due to an > exception: Bug in input gate/channel logic: input gate gotnotified by > channel about available data, but none was available. > at > org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:471) > at > org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:362) > at > org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:205) > at java.lang.Thread.run(Thread.java:701) > Caused by: java.lang.RuntimeException: Error obtaining the sorted > input: Thread 'SortMerger Reading Thread' terminated due to an > exception: Bug in input gate/channel logic: input gate gotnotified by > channel about available data, but none was available. > at > org.apache.flink.runtime.operators.sort.UnilateralSortMerger.getIterator(UnilateralSortMerger.java:607) > at > org.apache.flink.runtime.operators.RegularPactTask.getInput(RegularPactTask.java:1131) > at > org.apache.flink.runtime.operators.GroupReduceDriver.prepare(GroupReduceDriver.java:94) > at > org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:466) > ... 3 more > Caused by: java.io.IOException: Thread 'SortMerger Reading Thread' > terminated due to an exception: Bug in input gate/channel logic: input > gate gotnotified by channel about available data, but none was > available. > at > org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:784) > Caused by: java.lang.IllegalStateException: Bug in input gate/channel > logic: input gate gotnotified by channel about available data, but > none was available. > at > org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.getNextBufferOrEvent(SingleInputGate.java:314) > at > org.apache.flink.runtime.io.network.partition.consumer.UnionInputGate.getNextBufferOrEvent(UnionInputGate.java:141) > at > org.apache.flink.runtime.io.network.api.reader.AbstractRecordReader.getNextRecord(AbstractRecordReader.java:75) > at > org.apache.flink.runtime.io.network.api.reader.MutableRecordReader.next(MutableRecordReader.java:34) > at > org.apache.flink.runtime.operators.util.ReaderIterator.next(ReaderIterator.java:59) > at > org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ReadingThread.go(UnilateralSortMerger.java:958) > at > org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:781) > > 03/10/2015 13:44:10 Reduce(SUM(1), at > getDegrees(Graph.java:664)(15/16) switched to FAILED > java.lang.Exception: The data preparation for task 'Reduce(SUM(1), at > getDegrees(Graph.java:664)' , caused an error: Error obtaining the > sorted input: Thread 'SortMerger Reading Thread' terminated due to an > exception: Bug in input gate/channel logic: input gate gotnotified by > channel about available data, but none was available. > at > org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:471) > at > org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:362) > at > org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:205) > at java.lang.Thread.run(Thread.java:701) > Caused by: java.lang.RuntimeException: Error obtaining the sorted > input: Thread 'SortMerger Reading Thread' terminated due to an > exception: Bug in input gate/channel logic: input gate gotnotified by > channel about available data, but none was available. > at > org.apache.flink.runtime.operators.sort.UnilateralSortMerger.getIterator(UnilateralSortMerger.java:607) > at > org.apache.flink.runtime.operators.RegularPactTask.getInput(RegularPactTask.java:1131) > at > org.apache.flink.runtime.operators.GroupReduceDriver.prepare(GroupReduceDriver.java:94) > at > org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:466) > ... 3 more > Caused by: java.io.IOException: Thread 'SortMerger Reading Thread' > terminated due to an exception: Bug in input gate/channel logic: input > gate gotnotified by channel about available data, but none was > available. > at > org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:784) > Caused by: java.lang.IllegalStateException: Bug in input gate/channel > logic: input gate gotnotified by channel about available data, but > none was available. > at > org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.getNextBufferOrEvent(SingleInputGate.java:314) > at > org.apache.flink.runtime.io.network.partition.consumer.UnionInputGate.getNextBufferOrEvent(UnionInputGate.java:141) > at > org.apache.flink.runtime.io.network.api.reader.AbstractRecordReader.getNextRecord(AbstractRecordReader.java:75) > at > org.apache.flink.runtime.io.network.api.reader.MutableRecordReader.next(MutableRecordReader.java:34) > at > org.apache.flink.runtime.operators.util.ReaderIterator.next(ReaderIterator.java:59) > at > org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ReadingThread.go(UnilateralSortMerger.java:958) > at > org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:781) > > 03/10/2015 13:44:10 Reduce(SUM(1), at getDegrees(Graph.java:664)(1/16) > switched to CANCELED > 03/10/2015 13:44:10 Reduce(SUM(1), at > getDegrees(Graph.java:664)(16/16) switched to FAILED > java.lang.Exception: The data preparation for task 'Reduce(SUM(1), at > getDegrees(Graph.java:664)' , caused an error: Error obtaining the > sorted input: Thread 'SortMerger Reading Thread' terminated due to an > exception: Bug in input gate/channel logic: input gate gotnotified by > channel about available data, but none was available. > at > org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:471) > at > org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:362) > at > org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:205) > at java.lang.Thread.run(Thread.java:701) > Caused by: java.lang.RuntimeException: Error obtaining the sorted > input: Thread 'SortMerger Reading Thread' terminated due to an > exception: Bug in input gate/channel logic: input gate gotnotified by > channel about available data, but none was available. > at > org.apache.flink.runtime.operators.sort.UnilateralSortMerger.getIterator(UnilateralSortMerger.java:607) > at > org.apache.flink.runtime.operators.RegularPactTask.getInput(RegularPactTask.java:1131) > at > org.apache.flink.runtime.operators.GroupReduceDriver.prepare(GroupReduceDriver.java:94) > at > org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:466) > ... 3 more > Caused by: java.io.IOException: Thread 'SortMerger Reading Thread' > terminated due to an exception: Bug in input gate/channel logic: input > gate gotnotified by channel about available data, but none was > available. > at > org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:784) > Caused by: java.lang.IllegalStateException: Bug in input gate/channel > logic: input gate gotnotified by channel about available data, but > none was available. > at > org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.getNextBufferOrEvent(SingleInputGate.java:314) > at > org.apache.flink.runtime.io.network.partition.consumer.UnionInputGate.getNextBufferOrEvent(UnionInputGate.java:141) > at > org.apache.flink.runtime.io.network.api.reader.AbstractRecordReader.getNextRecord(AbstractRecordReader.java:75) > at > org.apache.flink.runtime.io.network.api.reader.MutableRecordReader.next(MutableRecordReader.java:34) > at > org.apache.flink.runtime.operators.util.ReaderIterator.next(ReaderIterator.java:59) > at > org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ReadingThread.go(UnilateralSortMerger.java:958) > at > org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:781) > > 03/10/2015 13:44:10 Reduce(SUM(1), at getDegrees(Graph.java:664)(2/16) > switched to FAILED > java.lang.Exception: The data preparation for task 'Reduce(SUM(1), at > getDegrees(Graph.java:664)' , caused an error: Error obtaining the > sorted input: Thread 'SortMerger Reading Thread' terminated due to an > exception: Bug in input gate/channel logic: input gate gotnotified by > channel about available data, but none was available. > at > org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:471) > at > org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:362) > at > org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:205) > at java.lang.Thread.run(Thread.java:701) > Caused by: java.lang.RuntimeException: Error obtaining the sorted > input: Thread 'SortMerger Reading Thread' terminated due to an > exception: Bug in input gate/channel logic: input gate gotnotified by > channel about available data, but none was available. > at > org.apache.flink.runtime.operators.sort.UnilateralSortMerger.getIterator(UnilateralSortMerger.java:607) > at > org.apache.flink.runtime.operators.RegularPactTask.getInput(RegularPactTask.java:1131) > at > org.apache.flink.runtime.operators.GroupReduceDriver.prepare(GroupReduceDriver.java:94) > at > org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:466) > ... 3 more > Caused by: java.io.IOException: Thread 'SortMerger Reading Thread' > terminated due to an exception: Bug in input gate/channel logic: input > gate gotnotified by channel about available data, but none was > available. > at > org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:784) > Caused by: java.lang.IllegalStateException: Bug in input gate/channel > logic: input gate gotnotified by channel about available data, but > none was available. > at > org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.getNextBufferOrEvent(SingleInputGate.java:314) > at > org.apache.flink.runtime.io.network.partition.consumer.UnionInputGate.getNextBufferOrEvent(UnionInputGate.java:141) > at > org.apache.flink.runtime.io.network.api.reader.AbstractRecordReader.getNextRecord(AbstractRecordReader.java:75) > at > org.apache.flink.runtime.io.network.api.reader.MutableRecordReader.next(MutableRecordReader.java:34) > at > org.apache.flink.runtime.operators.util.ReaderIterator.next(ReaderIterator.java:59) > at > org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ReadingThread.go(UnilateralSortMerger.java:958) > at > org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:781) > > 03/10/2015 13:44:10 Job execution switched to status FAILED. > 03/10/2015 13:44:11 Job execution switched to status RUNNING. > 03/10/2015 13:44:11 DataSource (at > getLongLongEdgeInvalidSrcTrgData(TestGraphUtils.java:75) > (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to > SCHEDULED > 03/10/2015 13:44:11 DataSource (at > getLongLongEdgeInvalidSrcTrgData(TestGraphUtils.java:75) > (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to > DEPLOYING > 03/10/2015 13:44:11 DataSource (at > getLongLongVertexData(TestGraphUtils.java:37) > (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to > SCHEDULED > 03/10/2015 13:44:11 DataSource (at > getLongLongVertexData(TestGraphUtils.java:37) > (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to > DEPLOYING > 03/10/2015 13:44:11 DataSource (at > getLongLongEdgeInvalidSrcTrgData(TestGraphUtils.java:75) > (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to > RUNNING > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(1/16) switched to SCHEDULED > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(1/16) switched to DEPLOYING > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(2/16) switched to SCHEDULED > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(2/16) switched to DEPLOYING > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(3/16) switched to SCHEDULED > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(4/16) switched to SCHEDULED > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(3/16) switched to DEPLOYING > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(4/16) switched to DEPLOYING > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(5/16) switched to SCHEDULED > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(6/16) switched to SCHEDULED > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(5/16) switched to DEPLOYING > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(6/16) switched to DEPLOYING > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(7/16) switched to SCHEDULED > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(7/16) switched to DEPLOYING > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(8/16) switched to SCHEDULED > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(8/16) switched to DEPLOYING > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(9/16) switched to SCHEDULED > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(9/16) switched to DEPLOYING > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(10/16) switched to SCHEDULED > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(10/16) switched to DEPLOYING > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(11/16) switched to SCHEDULED > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(11/16) switched to DEPLOYING > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(12/16) switched to SCHEDULED > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(12/16) switched to DEPLOYING > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(13/16) switched to SCHEDULED > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(14/16) switched to SCHEDULED > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(13/16) switched to DEPLOYING > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(14/16) switched to DEPLOYING > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(15/16) switched to SCHEDULED > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(15/16) switched to DEPLOYING > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(16/16) switched to SCHEDULED > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(16/16) switched to DEPLOYING > 03/10/2015 13:44:11 DataSource (at > getLongLongVertexData(TestGraphUtils.java:37) > (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to > RUNNING > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(1/16) switched to SCHEDULED > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(1/16) switched to DEPLOYING > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(2/16) switched to SCHEDULED > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(2/16) switched to DEPLOYING > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(1/16) switched to RUNNING > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(3/16) switched to SCHEDULED > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(3/16) switched to DEPLOYING > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(4/16) switched to SCHEDULED > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(4/16) switched to DEPLOYING > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(5/16) switched to SCHEDULED > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(5/16) switched to DEPLOYING > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(6/16) switched to SCHEDULED > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(6/16) switched to DEPLOYING > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(7/16) switched to SCHEDULED > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(7/16) switched to DEPLOYING > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(8/16) switched to SCHEDULED > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(8/16) switched to DEPLOYING > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(9/16) switched to SCHEDULED > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(9/16) switched to DEPLOYING > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(10/16) switched to SCHEDULED > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(10/16) switched to DEPLOYING > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(11/16) switched to SCHEDULED > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(11/16) switched to DEPLOYING > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(12/16) switched to SCHEDULED > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(13/16) switched to SCHEDULED > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(12/16) switched to DEPLOYING > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(13/16) switched to DEPLOYING > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(14/16) switched to SCHEDULED > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(14/16) switched to DEPLOYING > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(15/16) switched to SCHEDULED > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(15/16) switched to DEPLOYING > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(16/16) switched to SCHEDULED > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(16/16) switched to DEPLOYING > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(2/16) switched to RUNNING > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(3/16) switched to RUNNING > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(4/16) switched to RUNNING > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(5/16) switched to RUNNING > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(7/16) switched to RUNNING > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(8/16) switched to RUNNING > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(9/16) switched to RUNNING > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(10/16) switched to RUNNING > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(6/16) switched to RUNNING > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(11/16) switched to RUNNING > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(12/16) switched to RUNNING > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(13/16) switched to RUNNING > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(1/16) switched to RUNNING > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(2/16) switched to RUNNING > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(3/16) switched to RUNNING > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(4/16) switched to RUNNING > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(5/16) switched to RUNNING > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(6/16) switched to RUNNING > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(8/16) switched to RUNNING > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(9/16) switched to RUNNING > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(10/16) switched to RUNNING > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(11/16) switched to RUNNING > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(12/16) switched to RUNNING > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(13/16) switched to RUNNING > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(14/16) switched to RUNNING > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(15/16) switched to RUNNING > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(16/16) switched to RUNNING > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(14/16) switched to RUNNING > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(7/16) switched to RUNNING > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(16/16) switched to RUNNING > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(15/16) switched to RUNNING > 03/10/2015 13:44:11 DataSource (at > getLongLongEdgeInvalidSrcTrgData(TestGraphUtils.java:75) > (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to > FINISHED > 03/10/2015 13:44:11 Reduce(SUM(1), at getDegrees(Graph.java:664)(1/16) > switched to SCHEDULED > 03/10/2015 13:44:11 Reduce(SUM(1), at getDegrees(Graph.java:664)(1/16) > switched to DEPLOYING > 03/10/2015 13:44:11 Reduce(SUM(1), at getDegrees(Graph.java:664)(2/16) > switched to SCHEDULED > 03/10/2015 13:44:11 Reduce(SUM(1), at getDegrees(Graph.java:664)(2/16) > switched to DEPLOYING > 03/10/2015 13:44:11 Reduce(SUM(1), at getDegrees(Graph.java:664)(3/16) > switched to SCHEDULED > 03/10/2015 13:44:11 Reduce(SUM(1), at getDegrees(Graph.java:664)(3/16) > switched to DEPLOYING > 03/10/2015 13:44:11 Reduce(SUM(1), at getDegrees(Graph.java:664)(4/16) > switched to SCHEDULED > 03/10/2015 13:44:11 Reduce(SUM(1), at getDegrees(Graph.java:664)(4/16) > switched to DEPLOYING > 03/10/2015 13:44:11 Reduce(SUM(1), at getDegrees(Graph.java:664)(5/16) > switched to SCHEDULED > 03/10/2015 13:44:11 Reduce(SUM(1), at getDegrees(Graph.java:664)(5/16) > switched to DEPLOYING > 03/10/2015 13:44:11 Reduce(SUM(1), at getDegrees(Graph.java:664)(6/16) > switched to SCHEDULED > 03/10/2015 13:44:11 Reduce(SUM(1), at getDegrees(Graph.java:664)(6/16) > switched to DEPLOYING > 03/10/2015 13:44:11 Reduce(SUM(1), at getDegrees(Graph.java:664)(7/16) > switched to SCHEDULED > 03/10/2015 13:44:11 Reduce(SUM(1), at getDegrees(Graph.java:664)(7/16) > switched to DEPLOYING > 03/10/2015 13:44:11 Reduce(SUM(1), at getDegrees(Graph.java:664)(8/16) > switched to SCHEDULED > 03/10/2015 13:44:11 Reduce(SUM(1), at getDegrees(Graph.java:664)(8/16) > switched to DEPLOYING > 03/10/2015 13:44:11 Reduce(SUM(1), at getDegrees(Graph.java:664)(9/16) > switched to SCHEDULED > 03/10/2015 13:44:11 Reduce(SUM(1), at > getDegrees(Graph.java:664)(10/16) switched to SCHEDULED > 03/10/2015 13:44:11 Reduce(SUM(1), at getDegrees(Graph.java:664)(9/16) > switched to DEPLOYING > 03/10/2015 13:44:11 Reduce(SUM(1), at > getDegrees(Graph.java:664)(10/16) switched to DEPLOYING > 03/10/2015 13:44:11 Reduce(SUM(1), at > getDegrees(Graph.java:664)(11/16) switched to SCHEDULED > 03/10/2015 13:44:11 Reduce(SUM(1), at > getDegrees(Graph.java:664)(12/16) switched to SCHEDULED > 03/10/2015 13:44:11 Reduce(SUM(1), at > getDegrees(Graph.java:664)(11/16) switched to DEPLOYING > 03/10/2015 13:44:11 Reduce(SUM(1), at > getDegrees(Graph.java:664)(12/16) switched to DEPLOYING > 03/10/2015 13:44:11 Reduce(SUM(1), at > getDegrees(Graph.java:664)(13/16) switched to SCHEDULED > 03/10/2015 13:44:11 Reduce(SUM(1), at > getDegrees(Graph.java:664)(14/16) switched to SCHEDULED > 03/10/2015 13:44:11 Reduce(SUM(1), at > getDegrees(Graph.java:664)(13/16) switched to DEPLOYING > 03/10/2015 13:44:11 Reduce(SUM(1), at > getDegrees(Graph.java:664)(14/16) switched to DEPLOYING > 03/10/2015 13:44:11 Reduce(SUM(1), at > getDegrees(Graph.java:664)(15/16) switched to SCHEDULED > 03/10/2015 13:44:11 Reduce(SUM(1), at > getDegrees(Graph.java:664)(16/16) switched to SCHEDULED > 03/10/2015 13:44:11 Reduce(SUM(1), at > getDegrees(Graph.java:664)(15/16) switched to DEPLOYING > 03/10/2015 13:44:11 Reduce(SUM(1), at > getDegrees(Graph.java:664)(16/16) switched to DEPLOYING > 03/10/2015 13:44:11 DataSource (at > getLongLongVertexData(TestGraphUtils.java:37) > (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to > FINISHED > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(4/16) switched to FINISHED > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(6/16) switched to FINISHED > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(9/16) switched to FINISHED > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(11/16) switched to FINISHED > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(16/16) switched to FINISHED > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(14/16) switched to FINISHED > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(2/16) switched to FINISHED > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(14/16) switched to FINISHED > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(12/16) switched to FINISHED > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(10/16) switched to FINISHED > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(1/16) switched to FINISHED > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(5/16) switched to FINISHED > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(3/16) switched to FINISHED > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(7/16) switched to FINISHED > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(8/16) switched to FINISHED > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(16/16) switched to FINISHED > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(1/16) switched to FAILED > java.util.NoSuchElementException: The edge src/trg id could not be > found within the vertexIds > at > org.apache.flink.graph.Graph$CountNeighborsCoGroup.coGroup(Graph.java:643) > at > org.apache.flink.runtime.operators.CoGroupDriver.run(CoGroupDriver.java:152) > at > org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:496) > at > org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:362) > at > org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:205) > at java.lang.Thread.run(Thread.java:701) > > 03/10/2015 13:44:11 Job execution switched to status FAILING. > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(2/16) switched to CANCELING > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(3/16) switched to CANCELING > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(4/16) switched to CANCELING > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(5/16) switched to CANCELING > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(6/16) switched to CANCELING > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(7/16) switched to CANCELING > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(8/16) switched to CANCELING > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(9/16) switched to CANCELING > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(10/16) switched to CANCELING > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(11/16) switched to CANCELING > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(12/16) switched to CANCELING > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(13/16) switched to CANCELING > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(15/16) switched to CANCELING > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(15/16) switched to CANCELING > 03/10/2015 13:44:11 Reduce(SUM(1), at getDegrees(Graph.java:664)(1/16) > switched to CANCELING > 03/10/2015 13:44:11 Reduce(SUM(1), at getDegrees(Graph.java:664)(2/16) > switched to CANCELING > 03/10/2015 13:44:11 Reduce(SUM(1), at getDegrees(Graph.java:664)(3/16) > switched to CANCELING > 03/10/2015 13:44:11 Reduce(SUM(1), at getDegrees(Graph.java:664)(4/16) > switched to CANCELING > 03/10/2015 13:44:11 Reduce(SUM(1), at getDegrees(Graph.java:664)(5/16) > switched to CANCELING > 03/10/2015 13:44:11 Reduce(SUM(1), at getDegrees(Graph.java:664)(6/16) > switched to CANCELING > 03/10/2015 13:44:11 Reduce(SUM(1), at getDegrees(Graph.java:664)(7/16) > switched to CANCELING > 03/10/2015 13:44:11 Reduce(SUM(1), at getDegrees(Graph.java:664)(8/16) > switched to CANCELING > 03/10/2015 13:44:11 Reduce(SUM(1), at getDegrees(Graph.java:664)(9/16) > switched to CANCELING > 03/10/2015 13:44:11 Reduce(SUM(1), at > getDegrees(Graph.java:664)(10/16) switched to CANCELING > 03/10/2015 13:44:11 Reduce(SUM(1), at > getDegrees(Graph.java:664)(11/16) switched to CANCELING > 03/10/2015 13:44:11 Reduce(SUM(1), at > getDegrees(Graph.java:664)(12/16) switched to CANCELING > 03/10/2015 13:44:11 Reduce(SUM(1), at > getDegrees(Graph.java:664)(13/16) switched to CANCELING > 03/10/2015 13:44:11 Reduce(SUM(1), at > getDegrees(Graph.java:664)(14/16) switched to CANCELING > 03/10/2015 13:44:11 Reduce(SUM(1), at > getDegrees(Graph.java:664)(15/16) switched to CANCELING > 03/10/2015 13:44:11 Reduce(SUM(1), at > getDegrees(Graph.java:664)(16/16) switched to CANCELING > 03/10/2015 13:44:11 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@141689ca > )(1/16) > switched to CANCELED > 03/10/2015 13:44:11 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@141689ca > )(2/16) > switched to CANCELED > 03/10/2015 13:44:11 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@141689ca > )(3/16) > switched to CANCELED > 03/10/2015 13:44:11 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@141689ca > )(4/16) > switched to CANCELED > 03/10/2015 13:44:11 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@141689ca > )(5/16) > switched to CANCELED > 03/10/2015 13:44:11 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@141689ca > )(6/16) > switched to CANCELED > 03/10/2015 13:44:11 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@141689ca > )(7/16) > switched to CANCELED > 03/10/2015 13:44:11 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@141689ca > )(8/16) > switched to CANCELED > 03/10/2015 13:44:11 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@141689ca > )(9/16) > switched to CANCELED > 03/10/2015 13:44:11 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@141689ca > )(10/16) > switched to CANCELED > 03/10/2015 13:44:11 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@141689ca > )(11/16) > switched to CANCELED > 03/10/2015 13:44:11 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@141689ca > )(12/16) > switched to CANCELED > 03/10/2015 13:44:11 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@141689ca > )(13/16) > switched to CANCELED > 03/10/2015 13:44:11 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@141689ca > )(14/16) > switched to CANCELED > 03/10/2015 13:44:11 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@141689ca > )(15/16) > switched to CANCELED > 03/10/2015 13:44:11 > DataSink(org.apache.flink.api.java.io.DiscardingOutputFormat@141689ca > )(16/16) > switched to CANCELED > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(13/16) switched to FAILED > java.util.NoSuchElementException: The edge src/trg id could not be > found within the vertexIds > at > org.apache.flink.graph.Graph$CountNeighborsCoGroup.coGroup(Graph.java:643) > at > org.apache.flink.runtime.operators.CoGroupDriver.run(CoGroupDriver.java:152) > at > org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:496) > at > org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:362) > at > org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:205) > at java.lang.Thread.run(Thread.java:701) > > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(2/16) switched to CANCELED > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(3/16) switched to CANCELED > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(4/16) switched to CANCELED > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(5/16) switched to CANCELED > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(8/16) switched to CANCELED > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(7/16) switched to CANCELED > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(6/16) switched to CANCELED > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(9/16) switched to FAILED > java.util.NoSuchElementException: The edge src/trg id could not be > found within the vertexIds > at > org.apache.flink.graph.Graph$CountNeighborsCoGroup.coGroup(Graph.java:643) > at > org.apache.flink.runtime.operators.CoGroupDriver.run(CoGroupDriver.java:152) > at > org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:496) > at > org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:362) > at > org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:205) > at java.lang.Thread.run(Thread.java:701) > > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(10/16) switched to CANCELED > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(13/16) switched to CANCELED > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(12/16) switched to CANCELED > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(11/16) switched to CANCELED > 03/10/2015 13:44:11 CoGroup (CoGroup at > outDegrees(Graph.java:625))(15/16) switched to CANCELED > 03/10/2015 13:44:11 CoGroup (CoGroup at > inDegrees(Graph.java:655))(15/16) switched to CANCELED > 03/10/2015 13:44:11 Reduce(SUM(1), at getDegrees(Graph.java:664)(7/16) > switched to CANCELED > 03/10/2015 13:44:11 Reduce(SUM(1), at > getDegrees(Graph.java:664)(16/16) switched to CANCELED > 03/10/2015 13:44:11 Reduce(SUM(1), at getDegrees(Graph.java:664)(3/16) > switched to CANCELED > 03/10/2015 13:44:11 Reduce(SUM(1), at getDegrees(Graph.java:664)(2/16) > switched to CANCELED > 03/10/2015 13:44:11 Reduce(SUM(1), at > getDegrees(Graph.java:664)(14/16) switched to CANCELED > 03/10/2015 13:44:11 Reduce(SUM(1), at > getDegrees(Graph.java:664)(13/16) switched to CANCELED > 03/10/2015 13:44:11 Reduce(SUM(1), at > getDegrees(Graph.java:664)(12/16) switched to CANCELED > 03/10/2015 13:44:11 Reduce(SUM(1), at > getDegrees(Graph.java:664)(11/16) switched to CANCELED > 03/10/2015 13:44:11 Reduce(SUM(1), at > getDegrees(Graph.java:664)(10/16) switched to CANCELED > 03/10/2015 13:44:11 Reduce(SUM(1), at getDegrees(Graph.java:664)(9/16) > switched to CANCELED > 03/10/2015 13:44:11 Reduce(SUM(1), at getDegrees(Graph.java:664)(6/16) > switched to CANCELED > 03/10/2015 13:44:11 Reduce(SUM(1), at getDegrees(Graph.java:664)(5/16) > switched to CANCELED > 03/10/2015 13:44:11 Reduce(SUM(1), at getDegrees(Graph.java:664)(4/16) > switched to CANCELED > 03/10/2015 13:44:11 Reduce(SUM(1), at getDegrees(Graph.java:664)(8/16) > switched to FAILED > java.lang.Exception: The data preparation for task 'Reduce(SUM(1), at > getDegrees(Graph.java:664)' , caused an error: Error obtaining the > sorted input: Thread 'SortMerger Reading Thread' terminated due to an > exception: Intermediate result partition has already been released. > at > org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:471) > at > org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:362) > at > org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:205) > at java.lang.Thread.run(Thread.java:701) > Caused by: java.lang.RuntimeException: Error obtaining the sorted > input: Thread 'SortMerger Reading Thread' terminated due to an > exception: Intermediate result partition has already been released. > at > org.apache.flink.runtime.operators.sort.UnilateralSortMerger.getIterator(UnilateralSortMerger.java:607) > at > org.apache.flink.runtime.operators.RegularPactTask.getInput(RegularPactTask.java:1131) > at > org.apache.flink.runtime.operators.GroupReduceDriver.prepare(GroupReduceDriver.java:94) > at > org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:466) > ... 3 more > Caused by: java.io.IOException: Thread 'SortMerger Reading Thread' > terminated due to an exception: Intermediate result partition has > already been released. > at > org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:784) > Caused by: > org.apache.flink.runtime.io.network.partition.queue.IllegalQueueIteratorRequestException: > Intermediate result partition has already been released. > at > org.apache.flink.runtime.io.network.partition.IntermediateResultPartition.getQueueIterator(IntermediateResultPartition.java:222) > at > org.apache.flink.runtime.io.network.partition.IntermediateResultPartitionManager.getIntermediateResultPartitionIterator(IntermediateResultPartitionManager.java:136) > at > org.apache.flink.runtime.io.network.partition.consumer.LocalInputChannel.requestIntermediateResultPartition(LocalInputChannel.java:78) > at > org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.requestPartitions(SingleInputGate.java:287) > at > org.apache.flink.runtime.io.network.partition.consumer.UnionInputGate.requestPartitions(UnionInputGate.java:126) > at > org.apache.flink.runtime.io.network.partition.consumer.UnionInputGate.getNextBufferOrEvent(UnionInputGate.java:137) > at > org.apache.flink.runtime.io.network.api.reader.AbstractRecordReader.getNextRecord(AbstractRecordReader.java:75) > at > org.apache.flink.runtime.io.network.api.reader.MutableRecordReader.next(MutableRecordReader.java:34) > at > org.apache.flink.runtime.operators.util.ReaderIterator.next(ReaderIterator.java:59) > at > org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ReadingThread.go(UnilateralSortMerger.java:958) > at > org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:781) > > 03/10/2015 13:44:11 Reduce(SUM(1), at getDegrees(Graph.java:664)(1/16) > switched to FAILED > java.lang.Exception: The data preparation for task 'Reduce(SUM(1), at > getDegrees(Graph.java:664)' , caused an error: Error obtaining the > sorted input: Thread 'SortMerger Reading Thread' terminated due to an > exception: Bug in input gate/channel logic: input gate gotnotified by > channel about available data, but none was available. > at > org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:471) > at > org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:362) > at > org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:205) > at java.lang.Thread.run(Thread.java:701) > Caused by: java.lang.RuntimeException: Error obtaining the sorted > input: Thread 'SortMerger Reading Thread' terminated due to an > exception: Bug in input gate/channel logic: input gate gotnotified by > channel about available data, but none was available. > at > org.apache.flink.runtime.operators.sort.UnilateralSortMerger.getIterator(UnilateralSortMerger.java:607) > at > org.apache.flink.runtime.operators.RegularPactTask.getInput(RegularPactTask.java:1131) > at > org.apache.flink.runtime.operators.GroupReduceDriver.prepare(GroupReduceDriver.java:94) > at > org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:466) > ... 3 more > Caused by: java.io.IOException: Thread 'SortMerger Reading Thread' > terminated due to an exception: Bug in input gate/channel logic: input > gate gotnotified by channel about available data, but none was > available. > at > org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:784) > Caused by: java.lang.IllegalStateException: Bug in input gate/channel > logic: input gate gotnotified by channel about available data, but > none was available. > at > org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.getNextBufferOrEvent(SingleInputGate.java:314) > at > org.apache.flink.runtime.io.network.partition.consumer.UnionInputGate.getNextBufferOrEvent(UnionInputGate.java:141) > at > org.apache.flink.runtime.io.network.api.reader.AbstractRecordReader.getNextRecord(AbstractRecordReader.java:75) > at > org.apache.flink.runtime.io.network.api.reader.MutableRecordReader.next(MutableRecordReader.java:34) > at > org.apache.flink.runtime.operators.util.ReaderIterator.next(ReaderIterator.java:59) > at > org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ReadingThread.go(UnilateralSortMerger.java:958) > at > org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:781) > > 03/10/2015 13:44:11 Reduce(SUM(1), at > getDegrees(Graph.java:664)(15/16) switched to CANCELED > 03/10/2015 13:44:11 Job execution switched to status FAILED. > Tests run: 5, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 10.799 > sec - in org.apache.flink.graph.test.DegreesWithExceptionITCase > Running org.apache.flink.graph.test.VertexCentricConnectedComponentsITCase > Tests run: 8, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 11.046 > sec - in org.apache.flink.graph.test.WeaklyConnectedITCase > Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 6.749 > sec - in org.apache.flink.graph.test.VertexCentricConnectedComponentsITCase > > Results : > > Tests run: 180, Failures: 0, Errors: 0, Skipped: 0 > --001a11c3b61e7cb7450510efa30f--