Hi Maria, You also need to set the MasterCompute class, because that's where aggregators get registered (just like it's done in TstBspBasic.testBspMasterCompute where this vertex is used).
Maja From: Claudio Martella <[email protected]<mailto:[email protected]>> Reply-To: "[email protected]<mailto:[email protected]>" <[email protected]<mailto:[email protected]>> Date: Wednesday, February 13, 2013 6:56 AM To: "[email protected]<mailto:[email protected]>" <[email protected]<mailto:[email protected]>> Subject: Re: InputFormat for the example SimpleMasterComputeVertex in the latest trunk, this is line 42: double newValue= this.<DoubleWritable>getAggregatedValue(SMC_AGG).get(); What kind of input graph are you using? On Wed, Feb 13, 2013 at 1:25 PM, Maria Stylianou <[email protected]<mailto:[email protected]>> wrote: I didn't change anything in the code. I took the example as it is. Actually, the whole error message is this one: java.lang.IllegalStateException: run: Caught an unrecoverable exception waitFor: ExecutionException occurred while waiting for org.apache.giraph.utils.ProgressableUtils$FutureWaitable@1ea326f9 at org.apache.giraph.graph.GraphMapper.run(GraphMapper.java:102) at org.apache.hadoop.mapred.MapTask.runNewMapper(MapTask.java:763) at org.apache.hadoop.mapred.MapTask.run(MapTask.java:369) at org.apache.hadoop.mapred.Child$4.run(Child.java:259) at java.security.AccessController.doPrivileged(Native Method) at javax.security.auth.Subject.doAs(Subject.java:415) at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1059) at org.apache.hadoop.mapred.Child.main(Child.java:253) Caused by: java.lang.IllegalStateException: waitFor: ExecutionException occurred while waiting for org.apache.giraph.utils.ProgressableUtils$FutureWaitable@1ea326f9 at org.apache.giraph.utils.ProgressableUtils.waitFor(ProgressableUtils.java:145) at org.apache.giraph.utils.ProgressableUtils.waitForever(ProgressableUtils.java:105) at org.apache.giraph.utils.ProgressableUtils.getFutureResult(ProgressableUtils.java:67) at org.apache.giraph.graph.GraphTaskManager.processGraphPartitions(GraphTaskManager.java:723) at org.apache.giraph.graph.GraphTaskManager.execute(GraphTaskManager.java:270) at org.apache.giraph.graph.GraphMapper.run(GraphMapper.java:92) ... 7 more Caused by: java.util.concurrent.ExecutionException: java.lang.NullPointerException at java.util.concurrent.FutureTask$Sync.innerGet(FutureTask.java:262) at java.util.concurrent.FutureTask.get(FutureTask.java:119) at org.apache.giraph.utils.ProgressableUtils$FutureWaitable.waitFor(ProgressableUtils.java:232) at org.apache.giraph.utils.ProgressableUtils.waitFor(ProgressableUtils.java:137) ... 12 more Caused by: java.lang.NullPointerException at org.apache.giraph.examples.SimpleMasterComputeVertex.compute(SimpleMasterComputeVertex.java:42) at org.apache.giraph.graph.ComputeCallable.computePartition(ComputeCallable.java:204) at org.apache.giraph.graph.ComputeCallable.call(ComputeCallable.java:149) at org.apache.giraph.graph.ComputeCallable.call(ComputeCallable.java:63) at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:334) at java.util.concurrent.FutureTask.run(FutureTask.java:166) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603) at java.lang.Thread.run(Thread.java:722) On Wed, Feb 13, 2013 at 1:03 PM, Claudio Martella <[email protected]<mailto:[email protected]>> wrote: Are you sure that is the right line? I do not see how that would cause an exception, most probably a for loop on messages right after? On Wed, Feb 13, 2013 at 12:04 PM, Maria Stylianou <[email protected]<mailto:[email protected]>> wrote: Hey, I am trying to run the example SimpleMasterComputeVertex, but no matter which Input Format and graph I give, it doesn't work. Each worker gives the error: Caused by: java.lang.NullPointerException at org.apache.giraph.examples.SimpleMasterComputeVertex.compute(SimpleMasterComputeVertex.java:42) This line 42 is the first line of the compute() public void compute(Iterable<DoubleWritable> messages){ So I guess, the initialization is not done correctly, because the input file does not have the correct format. Any help would be appreciated, Thanks! Maria -- Maria Stylianou Intern at Telefonica, Barcelona, Spain Master Student of European Master in Distributed Computing<http://www.kth.se/en/studies/programmes/master/em/emdc> Universitat Politècnica de Catalunya - BarcelonaTech, Barcelona, Spain KTH Royal Institute of Technology, Stockholm, Sweden -- Claudio Martella [email protected]<mailto:[email protected]> -- Maria Stylianou Intern at Telefonica, Barcelona, Spain Master Student of European Master in Distributed Computing<http://www.kth.se/en/studies/programmes/master/em/emdc> Universitat Politècnica de Catalunya - BarcelonaTech, Barcelona, Spain KTH Royal Institute of Technology, Stockholm, Sweden -- Claudio Martella [email protected]<mailto:[email protected]>
