It looks like your compilation was not successful. You may need to fix those compilation error messages first before executing the code.
On 3 May 2014 22:13, Attila Dóró <[email protected]> wrote: > 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 >>
