I commented out that line, but now I get an ExecutionException:
java.util.concurrent.ExecutionException: java.lang.Error: Unresolved
compilation problem:
The method getAllPeerNames(TaskAttemptID) in the type PeerSyncClient is
not applicable for the arguments (BSPJobID)
at java.util.concurrent.FutureTask$Sync.innerGet(FutureTask.java:222)
at java.util.concurrent.FutureTask.get(FutureTask.java:83)
at
org.apache.hama.bsp.LocalBSPRunner$ThreadObserver.run(LocalBSPRunner.java:315)
at java.lang.Thread.run(Thread.java:662)
Caused by: java.lang.Error: Unresolved compilation problem:
The method getAllPeerNames(TaskAttemptID) in the type PeerSyncClient is
not applicable for the arguments (BSPJobID)
at org.apache.hama.bsp.BSPPeerImpl.initPeerNames(BSPPeerImpl.java:559)
at org.apache.hama.bsp.BSPPeerImpl.getNumPeers(BSPPeerImpl.java:553)
at
org.apache.hama.bsp.PartitioningRunner.bsp(PartitioningRunner.java:142)
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)
2014-05-03 7:10 GMT+02:00 Chia-Hung Lin <[email protected]>:
> If it's in trunk, then it may be a bug in that during
> LocalBSPRunner.transfer(), BSPPeerImpl.sync() looks like at the same
> time calling it.remove() which removes underlying BSPMessageBundle,
> resulting in EOFException.
>
> Any chance to comment out BSPPeerImpl.java at line 381 with code as below?
>
> ...
> final BSPMessageBundle<M> bundle = entry.getValue();
> // remove this message during runtime to save a bit of memory
> // it.remove(); <-- comment out this line
> try {
> messenger.transfer(addr, bundle);
> ...
>
> If that fixes the EOFException problem, then will need to create a
> ticket for that.
>
>
> On 3 May 2014 06:26, Attila Dóró <[email protected]> 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
>
