hama-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Edward J. Yoon" <edwardy...@apache.org>
Subject Re: getting EOFException
Date Sun, 04 May 2014 06:13:23 GMT
Hi,

Please check whether your MyWritableClass is implemented correctly.

On Sat, May 3, 2014 at 7:26 AM, Attila Dóró <doroattila@gmail.com> wrote:
> Hi,
>
> I try to write a graph algorithm, but I get EOFException and I can't find
> where is the mistake.
> I use the SSSP<https://github.com/apache/hama/blob/trunk/examples/src/main/java/org/apache/hama/examples/SSSP.java>
> example
> as a base. I tried this example and it worked well. I modified the compute
> function and some other lines in the SSSP, but I didn't modify the
> SSSPTextReader class, which extends the VertexInputReader. I know that the
> EOFException "signals that an end of file or end of stream has been reached
> unexpectedly during input", but I didn't modify any reader or input method,
> 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(LocalBSPRunner.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:288)
>     at
> org.apache.hama.bsp.LocalBSPRunner$BSPRunner.call(LocalBSPRunner.java:212)
>     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(ThreadPoolExecutor.java:886)
>     at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
>     at java.lang.Thread.run(Thread.java:662)
>
> I have no idea what is the problem, so if somebody could help me, I would
> really appreciate that.
>
> (Anyway, here <http://pastebin.com/3AHu8FnC> is my code, but I haven't used
> 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.

Mime
View raw message