Mailing-List: contact user-help@hama.apache.org; run by ezmlm
Precedence: bulk
Reply-To: user@hama.apache.org
MIME-Version: 1.0
In-Reply-To: 
 <CAGQgZQS9=r-GCaJh=g6t4-+yCr=WtABjRth_fD-mhaL_CxXrUA@mail.gmail.com>
References: 
 <CAKW9b-jfi2j8e8wWBcLUDFxZtaiLxj520bX-D0h3vV4=KrFdDQ@mail.gmail.com>
	<CAGQgZQS9=r-GCaJh=g6t4-+yCr=WtABjRth_fD-mhaL_CxXrUA@mail.gmail.com>
Date: Sun, 4 May 2014 15:32:03 +0900
Message-ID: 
 <CAGQgZQRWdrBgPNLQTQX=n7ci3gfx=CiLks7SpDtA956c6kyysQ@mail.gmail.com>
Subject: Re: getting EOFException
From: "Edward J. Yoon" <edwardyoon@apache.org>
To: "user@hama.apache.org" <user@hama.apache.org>
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: quoted-printable

I roughly read your code, and there's a bug, like
https://issues.apache.org/jira/browse/HAMA-868.

Modify you code to not use object references, and check your message
writable class.

On Sun, May 4, 2014 at 3:13 PM, Edward J. Yoon <edwardyoon@apache.org> wrot=
e:
> Hi,
>
> Please check whether your MyWritableClass is implemented correctly.
>
> On Sat, May 3, 2014 at 7:26 AM, Attila D=C3=B3r=C3=B3 <doroattila@gmail.c=
om> wrote:
>> Hi,
>>
>> I try to write a graph algorithm, but I get EOFException and I can't fin=
d
>> where is the mistake.
>> I use the SSSP<https://github.com/apache/hama/blob/trunk/examples/src/ma=
in/java/org/apache/hama/examples/SSSP.java>
>> example
>> as a base. I tried this example and it worked well. I modified the compu=
te
>> function and some other lines in the SSSP, but I didn't modify the
>> SSSPTextReader class, which extends the VertexInputReader. I know that t=
he
>> EOFException "signals that an end of file or end of stream has been reac=
hed
>> unexpectedly during input", but I didn't modify any reader or input meth=
od,
>> so I don't understand how can I get this exception.
>>
>> In the first superstep I get the proper output, but after the first
>> superstep I get this exception:
>>
>> java.io.EOFException
>>     at java.io.DataInputStream.readFully(DataInputStream.java:180)
>>     at java.io.DataInputStream.readFully(DataInputStream.java:152)
>>     at
>> org.apache.hama.bsp.BSPMessageBundle$1.next(BSPMessageBundle.java:157)
>>     at
>> org.apache.hama.bsp.BSPMessageBundle$1.next(BSPMessageBundle.java:118)
>>     at
>> org.apache.hama.bsp.LocalBSPRunner$LocalMessageManager.transfer(LocalBSP=
Runner.java:361)
>>     at org.apache.hama.bsp.BSPPeerImpl.sync(BSPPeerImpl.java:381)
>>     at org.apache.hama.graph.GraphJobRunner.bsp(GraphJobRunner.java:133)
>>     at
>> org.apache.hama.bsp.LocalBSPRunner$BSPRunner.run(LocalBSPRunner.java:258=
)
>>     at
>> org.apache.hama.bsp.LocalBSPRunner$BSPRunner.call(LocalBSPRunner.java:28=
8)
>>     at
>> org.apache.hama.bsp.LocalBSPRunner$BSPRunner.call(LocalBSPRunner.java:21=
2)
>>     at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303=
)
>>     at java.util.concurrent.FutureTask.run(FutureTask.java:138)
>>     at
>> java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:441)
>>     at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303=
)
>>     at java.util.concurrent.FutureTask.run(FutureTask.java:138)
>>     at
>> java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecuto=
r.java:886)
>>     at
>> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.ja=
va:908)
>>     at java.lang.Thread.run(Thread.java:662)
>>
>> I have no idea what is the problem, so if somebody could help me, I woul=
d
>> really appreciate that.
>>
>> (Anyway, here <http://pastebin.com/3AHu8FnC> is my code, but I haven't u=
sed
>> comment so I think it's totally incomprehensible for you)
>>
>> Thank you in advance for your help,
>> Attila
>
>
>
> --
> Best Regards, Edward J. Yoon
> CEO at DataSayer Co., Ltd.


--=20
Best Regards, Edward J. Yoon
CEO at DataSayer Co., Ltd.