Return-Path: 
 <user-return-2018-apmail-flink-user-archive=flink.apache.org@flink.apache.org>
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 3418D17A0D
	for <apmail-flink-user-archive@minotaur.apache.org>;
 Tue, 14 Jul 2015 12:12:39 +0000 (UTC)
Received: (qmail 44530 invoked by uid 500); 14 Jul 2015 12:12:39 -0000
Delivered-To: apmail-flink-user-archive@flink.apache.org
Received: (qmail 44465 invoked by uid 500); 14 Jul 2015 12:12:39 -0000
Mailing-List: contact user-help@flink.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:user-help@flink.apache.org>
List-Unsubscribe: <mailto:user-unsubscribe@flink.apache.org>
List-Post: <mailto:user@flink.apache.org>
List-Id: <user.flink.apache.org>
Reply-To: user@flink.apache.org
Delivered-To: mailing list user@flink.apache.org
Received: (qmail 44455 invoked by uid 99); 14 Jul 2015 12:12:39 -0000
Received: from Unknown (HELO spamd4-us-west.apache.org) (209.188.14.142)
    by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 14 Jul 2015 12:12:39 +0000
Received: from localhost (localhost [127.0.0.1])
	by spamd4-us-west.apache.org (ASF Mail Server at spamd4-us-west.apache.org)
 with ESMTP id 85FCFC0098
	for <user@flink.apache.org>; Tue, 14 Jul 2015 12:12:38 +0000 (UTC)
X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org
X-Spam-Flag: NO
X-Spam-Score: 2.99
X-Spam-Level: **
X-Spam-Status: No, score=2.99 tagged_above=-999 required=6.31
	tests=[HTML_MESSAGE=3, SPF_PASS=-0.001, T_RP_MATCHES_RCVD=-0.01,
	URIBL_BLOCKED=0.001] autolearn=disabled
Received: from mx1-us-east.apache.org ([10.40.0.8])
	by localhost (spamd4-us-west.apache.org [10.40.0.11]) (amavisd-new,
 port 10024)
	with ESMTP id VkAFg7Ve8D_F for <user@flink.apache.org>;
	Tue, 14 Jul 2015 12:12:29 +0000 (UTC)
Received: from mailout1.informatik.hu-berlin.de
 (mailout1.informatik.hu-berlin.de [141.20.20.101])
	by mx1-us-east.apache.org (ASF Mail Server at mx1-us-east.apache.org) with
 ESMTPS id 378DF4C0CE
	for <user@flink.apache.org>; Tue, 14 Jul 2015 12:12:28 +0000 (UTC)
Received: from mailbox.informatik.hu-berlin.de (mailbox [141.20.20.63])
	by mail.informatik.hu-berlin.de (8.14.7/8.14.7/INF-2.0-MA-SOLARIS-2.10-25)
 with ESMTP id t6ECCJxg023726
	(version=TLSv1/SSLv3 cipher=DHE-RSA-AES256-GCM-SHA384 bits=256 verify=OK)
	for <user@flink.apache.org>; Tue, 14 Jul 2015 14:12:20 +0200 (MEST)
Received: from [192.168.0.32] (ip5f5bd68e.dynamic.kabel-deutschland.de
 [95.91.214.142] (may be forged))
	(authenticated bits=0)
	by mailbox.informatik.hu-berlin.de
 (8.14.7/8.14.7/INF-2.0-MA-SOLARIS-2.10-AUTH-26-465-587) with ESMTP id
 t6ECCIDp023721
	(version=TLSv1/SSLv3 cipher=DHE-RSA-AES128-SHA bits=128 verify=NO)
	for <user@flink.apache.org>; Tue, 14 Jul 2015 14:12:19 +0200 (MEST)
Message-ID: <55A4FCA2.8080401@informatik.hu-berlin.de>
Date: Tue, 14 Jul 2015 14:12:18 +0200
From: Mihail Vieru <vieru@informatik.hu-berlin.de>
User-Agent: Mozilla/5.0 (Windows NT 6.1; WOW64;
 rv:31.0) Gecko/20100101 Thunderbird/31.7.0
MIME-Version: 1.0
To: user@flink.apache.org
Subject: Re: Gelly EOFException
References: 
 <CAELUF_BuQ9MU9FBMXDuAnxKr0N5XEw-PLxdLCv8KaJDLO_E7nw@mail.gmail.com>
 <CAK5ODX4VszNPpVxQrdwTLJqiUgY_OHSqPMSJQXeutkTd5GHh7A@mail.gmail.com>
In-Reply-To: 
 <CAK5ODX4VszNPpVxQrdwTLJqiUgY_OHSqPMSJQXeutkTd5GHh7A@mail.gmail.com>
Content-Type: multipart/alternative;
 boundary="------------050704040203090506040402"
X-Virus-Scanned: clamav-milter 0.98.4 at mailbox
X-Virus-Status: Clean
X-Greylist: Sender succeeded STARTTLS authentication,
 not delayed by milter-greylist-4.5.1 (mail.informatik.hu-berlin.de
 [141.20.20.50]); Tue, 14 Jul 2015 14:12:20 +0200 (MEST)

This is a multi-part message in MIME format.
--------------050704040203090506040402
Content-Type: text/plain; charset=utf-8; format=flowed
Content-Transfer-Encoding: 7bit

Hi,

looks very similar to this bug:
https://issues.apache.org/jira/browse/FLINK-1916

Best,
Mihail

On 14.07.2015 14:09, Andra Lungu wrote:
> Hi Flavio,
>
> Could you also show us a code snippet?
>
> On Tue, Jul 14, 2015 at 2:06 PM, Flavio Pompermaier 
> <pompermaier@okkam.it <mailto:pompermaier@okkam.it>> wrote:
>
>     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
>
>


--------------050704040203090506040402
Content-Type: text/html; charset=utf-8
Content-Transfer-Encoding: 8bit

<html>
  <head>
    <meta content="text/html; charset=utf-8" http-equiv="Content-Type">
  </head>
  <body bgcolor="#FFFFFF" text="#000000">
    Hi,<br>
    <br>
    looks very similar to this bug:<br>
    <a class="moz-txt-link-freetext" href="https://issues.apache.org/jira/browse/FLINK-1916">https://issues.apache.org/jira/browse/FLINK-1916</a><br>
    <br>
    Best,<br>
    Mihail<br>
    <br>
    <div class="moz-cite-prefix">On 14.07.2015 14:09, Andra Lungu wrote:<br>
    </div>
    <blockquote
cite="mid:CAK5ODX4VszNPpVxQrdwTLJqiUgY_OHSqPMSJQXeutkTd5GHh7A@mail.gmail.com"
      type="cite">
      <div dir="ltr">Hi Flavio, <br>
        <br>
        Could you also show us a code snippet? <br>
      </div>
      <div class="gmail_extra"><br>
        <div class="gmail_quote">On Tue, Jul 14, 2015 at 2:06 PM, Flavio
          Pompermaier <span dir="ltr">&lt;<a moz-do-not-send="true"
              href="mailto:pompermaier@okkam.it" target="_blank">pompermaier@okkam.it</a>&gt;</span>
          wrote:<br>
          <blockquote class="gmail_quote" style="margin:0 0 0
            .8ex;border-left:1px #ccc solid;padding-left:1ex">
            <div dir="ltr">Hi to all,
              <div>in my vertex centric iteration I get the following
                exception, am I doing something wrong or is it a bug of
                Gelly?</div>
              <div><br>
              </div>
              <div>
                <div>starting iteration [1]:  CoGroup (Messaging) (6/8)</div>
                <div>IterationHead(WorksetIteration (Vertex-centric
                  iteration
                  (test.gelly.functions.VUpdateFunction@1814786f
                  | test.gelly.functions.VMessagingFunction@67eecbc2)))
                  (4/8) switched to FAILED with exception.</div>
                <div>java.io.EOFException</div>
                <div><span style="white-space:pre-wrap"> </span>at
org.apache.flink.runtime.operators.hash.InMemoryPartition$WriteView.nextSegment(InMemoryPartition.java:333)</div>
                <div><span style="white-space:pre-wrap"> </span>at
org.apache.flink.runtime.memorymanager.AbstractPagedOutputView.advance(AbstractPagedOutputView.java:140)</div>
                <div><span style="white-space:pre-wrap"> </span>at
org.apache.flink.runtime.memorymanager.AbstractPagedOutputView.write(AbstractPagedOutputView.java:201)</div>
                <div><span style="white-space:pre-wrap"> </span>at
org.apache.flink.api.java.typeutils.runtime.DataOutputViewStream.write(DataOutputViewStream.java:39)</div>
                <div><span style="white-space:pre-wrap"> </span>at
                  com.esotericsoftware.kryo.io.Output.flush(Output.java:163)</div>
                <div><span style="white-space:pre-wrap"> </span>at
org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializer.serialize(KryoSerializer.java:187)</div>
                <div><span style="white-space:pre-wrap"> </span>at
org.apache.flink.api.java.typeutils.runtime.PojoSerializer.serialize(PojoSerializer.java:372)</div>
                <div><span style="white-space:pre-wrap"> </span>at
org.apache.flink.api.java.typeutils.runtime.TupleSerializer.serialize(TupleSerializer.java:116)</div>
                <div><span style="white-space:pre-wrap"> </span>at
org.apache.flink.api.java.typeutils.runtime.TupleSerializer.serialize(TupleSerializer.java:30)</div>
                <div><span style="white-space:pre-wrap"> </span>at
org.apache.flink.runtime.operators.hash.InMemoryPartition.appendRecord(InMemoryPartition.java:219)</div>
                <div><span style="white-space:pre-wrap"> </span>at
org.apache.flink.runtime.operators.hash.CompactingHashTable.insertOrReplaceRecord(CompactingHashTable.java:536)</div>
                <div><span style="white-space:pre-wrap"> </span>at
org.apache.flink.runtime.operators.hash.CompactingHashTable.buildTableWithUniqueKey(CompactingHashTable.java:347)</div>
                <div><span style="white-space:pre-wrap"> </span>at
org.apache.flink.runtime.iterative.task.IterationHeadPactTask.readInitialSolutionSet(IterationHeadPactTask.java:209)</div>
                <div><span style="white-space:pre-wrap"> </span>at
org.apache.flink.runtime.iterative.task.IterationHeadPactTask.run(IterationHeadPactTask.java:270)</div>
                <div><span style="white-space:pre-wrap"> </span>at
org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:362)</div>
                <div><span style="white-space:pre-wrap"> </span>at
                  org.apache.flink.runtime.taskmanager.Task.run(Task.java:559)</div>
                <div><span style="white-space:pre-wrap"> </span>at
                  java.lang.Thread.run(Thread.java:745)</div>
              </div>
              <div><br>
              </div>
              <div><br>
              </div>
              <div>Best,</div>
              <div>Flavio</div>
            </div>
          </blockquote>
        </div>
        <br>
      </div>
    </blockquote>
    <br>
  </body>
</html>

--------------050704040203090506040402--