Return-Path: X-Original-To: apmail-flink-user-archive@minotaur.apache.org Delivered-To: apmail-flink-user-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 8E2FB179F3 for ; Tue, 14 Jul 2015 12:08:44 +0000 (UTC) Received: (qmail 36436 invoked by uid 500); 14 Jul 2015 12:08:44 -0000 Delivered-To: apmail-flink-user-archive@flink.apache.org Received: (qmail 36361 invoked by uid 500); 14 Jul 2015 12:08:44 -0000 Mailing-List: contact user-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@flink.apache.org Delivered-To: mailing list user@flink.apache.org Received: (qmail 36351 invoked by uid 99); 14 Jul 2015 12:08:44 -0000 Received: from Unknown (HELO spamd1-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 14 Jul 2015 12:08:44 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd1-us-west.apache.org (ASF Mail Server at spamd1-us-west.apache.org) with ESMTP id E0BBAD47DE for ; Tue, 14 Jul 2015 12:08:43 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd1-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 3.98 X-Spam-Level: *** X-Spam-Status: No, score=3.98 tagged_above=-999 required=6.31 tests=[HTML_MESSAGE=3, KAM_LAZY_DOMAIN_SECURITY=1, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01] autolearn=disabled Received: from mx1-us-west.apache.org ([10.40.0.8]) by localhost (spamd1-us-west.apache.org [10.40.0.7]) (amavisd-new, port 10024) with ESMTP id n0EUfkVlRd9Q for ; Tue, 14 Jul 2015 12:08:42 +0000 (UTC) Received: from mail-yk0-f181.google.com (mail-yk0-f181.google.com [209.85.160.181]) by mx1-us-west.apache.org (ASF Mail Server at mx1-us-west.apache.org) with ESMTPS id 60C3B20EFB for ; Tue, 14 Jul 2015 12:08:42 +0000 (UTC) Received: by ykeo3 with SMTP id o3so5789882yke.0 for ; Tue, 14 Jul 2015 05:07:05 -0700 (PDT) X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20130820; h=x-gm-message-state:mime-version:from:date:message-id:subject:to :content-type; bh=b3vojoa/Q4fVrE3DZvrtoc9PkBJoYBR5U9QqF/hpyCU=; b=g8YkJ3YWFWf3wAuYXL6Jb/uh9sJVfHXR3PsuC/xhd38TJfQXw5gyv5Hnyh/xdSXRS+ JblrEz0reQdJzcf3c5sbaOVUA6jlIASlLGypjznJa4uZ+CGT2GxPfnELzB3KrB2sEcN9 KNYNmFvqPrdCDRX182ophDxGdxOp1F7fL+wRrmuEATA3m/5iPBVjie1N5SXsKQPqUOXS r0WsvKgy1Ch/ZbD7uQ/yRyQT/rVZh+1xAF0t5YdkpOdmRGsUAhmG0sPBpuGExKjPvjeY 2ztHsKNP+IL2T2n8fizNYwWRG/AVmSBVGIA7LTDToApTBqQcrnyuu9W+aOf0cu35vQtV 67Mw== X-Gm-Message-State: ALoCoQmAZTK5S17G1bSiO+uMU07+wYvVaoV5Y0R5+IoMP1HTbtKlwfgW31ZyVCQo1r9O0+BCDW6a X-Received: by 10.170.208.147 with SMTP id z141mr5297210yke.106.1436875625215; Tue, 14 Jul 2015 05:07:05 -0700 (PDT) MIME-Version: 1.0 Received: by 10.129.70.10 with HTTP; Tue, 14 Jul 2015 05:06:45 -0700 (PDT) X-Originating-IP: [213.203.177.29] From: Flavio Pompermaier Date: Tue, 14 Jul 2015 14:06:45 +0200 Message-ID: Subject: Gelly EOFException To: user Content-Type: multipart/alternative; boundary=001a113936463aa39c051ad4ad68 --001a113936463aa39c051ad4ad68 Content-Type: text/plain; charset=UTF-8 Hi to all, in my vertex centric iteration I get the following exception, am I doing something wrong or is it a bug of Gelly? starting iteration [1]: CoGroup (Messaging) (6/8) IterationHead(WorksetIteration (Vertex-centric iteration (test.gelly.functions.VUpdateFunction@1814786f | test.gelly.functions.VMessagingFunction@67eecbc2))) (4/8) switched to FAILED with exception. java.io.EOFException at org.apache.flink.runtime.operators.hash.InMemoryPartition$WriteView.nextSegment(InMemoryPartition.java:333) at org.apache.flink.runtime.memorymanager.AbstractPagedOutputView.advance(AbstractPagedOutputView.java:140) at org.apache.flink.runtime.memorymanager.AbstractPagedOutputView.write(AbstractPagedOutputView.java:201) at org.apache.flink.api.java.typeutils.runtime.DataOutputViewStream.write(DataOutputViewStream.java:39) at com.esotericsoftware.kryo.io.Output.flush(Output.java:163) at org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializer.serialize(KryoSerializer.java:187) at org.apache.flink.api.java.typeutils.runtime.PojoSerializer.serialize(PojoSerializer.java:372) at org.apache.flink.api.java.typeutils.runtime.TupleSerializer.serialize(TupleSerializer.java:116) at org.apache.flink.api.java.typeutils.runtime.TupleSerializer.serialize(TupleSerializer.java:30) at org.apache.flink.runtime.operators.hash.InMemoryPartition.appendRecord(InMemoryPartition.java:219) at org.apache.flink.runtime.operators.hash.CompactingHashTable.insertOrReplaceRecord(CompactingHashTable.java:536) at org.apache.flink.runtime.operators.hash.CompactingHashTable.buildTableWithUniqueKey(CompactingHashTable.java:347) at org.apache.flink.runtime.iterative.task.IterationHeadPactTask.readInitialSolutionSet(IterationHeadPactTask.java:209) at org.apache.flink.runtime.iterative.task.IterationHeadPactTask.run(IterationHeadPactTask.java:270) at org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:362) at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559) at java.lang.Thread.run(Thread.java:745) Best, Flavio --001a113936463aa39c051ad4ad68 Content-Type: text/html; charset=UTF-8 Content-Transfer-Encoding: quoted-printable
Hi to all,
=

in my vertex centric iteration I get the following exception, am I doi= ng something wrong or is it a bug of Gelly?

s= tarting iteration [1]: =C2=A0CoGroup (Messaging) (6/8)
IterationH= ead(WorksetIteration (Vertex-centric iteration (test.gelly.functions.VUpdat= eFunction@1814786f |=C2=A0test.gelly.functions.VMessagingFunction@67eecbc2)= )) (4/8) switched to FAILED with exception.
java.io.EOFException<= /div>
at org.apache.= flink.runtime.operators.hash.InMemoryPartition$WriteView.nextSegment(InMemo= ryPartition.java:333)
= at org.apache.flink.runtime.memorymanager.AbstractPagedOutputView.a= dvance(AbstractPagedOutputView.java:140)
at org.apache.flink.runtime.memorymanager.Abst= ractPagedOutputView.write(AbstractPagedOutputView.java:201)
at org.apache.flink.api.java.= typeutils.runtime.DataOutputViewStream.write(DataOutputViewStream.java:39)<= /div>
at com.esoteri= csoftware.kryo.io.Output.flush(Output.java:163)
at org.apache.flink.api.java.typeutils.ru= ntime.kryo.KryoSerializer.serialize(KryoSerializer.java:187)
at org.apache.flink.api.java= .typeutils.runtime.PojoSerializer.serialize(PojoSerializer.java:372)
<= div> at org.apache.flink.= api.java.typeutils.runtime.TupleSerializer.serialize(TupleSerializer.java:1= 16)
at org.apa= che.flink.api.java.typeutils.runtime.TupleSerializer.serialize(TupleSeriali= zer.java:30)
a= t org.apache.flink.runtime.operators.hash.InMemoryPartition.appendRecord(In= MemoryPartition.java:219)
at org.apache.flink.runtime.operators.hash.CompactingHashTable.= insertOrReplaceRecord(CompactingHashTable.java:536)
at org.apache.flink.runtime.operato= rs.hash.CompactingHashTable.buildTableWithUniqueKey(CompactingHashTable.jav= a:347)
at org.= apache.flink.runtime.iterative.task.IterationHeadPactTask.readInitialSoluti= onSet(IterationHeadPactTask.java:209)
at org.apache.flink.runtime.iterative.task.Iteratio= nHeadPactTask.run(IterationHeadPactTask.java:270)
at org.apache.flink.runtime.operators.R= egularPactTask.invoke(RegularPactTask.java:362)
at org.apache.flink.runtime.taskmanager.T= ask.run(Task.java:559)
at java.lang.Thread.run(Thread.java:745)


Best,
Flavio
--001a113936463aa39c051ad4ad68--