copy your jar file into lib dir. On Wed, Feb 26, 2014 at 12:05 AM, <[email protected]> wrote: > > Still the same error exists but with MyWritable as the class not found now. > This is the console after the job has started. I run it at local mode. I > even redownloaded the trunk and compiled it. > > > 14/02/25 18:51:40 INFO graph.GraphJobRunner: 2 vertices are loaded into > local:1 > 14/02/25 18:51:40 INFO graph.GraphJobRunner: 2 vertices are loaded into > local:0 >>>> >>>> 1 >>>> 1 > > java.io.IOException: can't find class: testhamayoon.TestHamaYoon$MyWritable > because testhamayoon.TestHamaYoon$MyWritable > >>>> >>>> > at > org.apache.hadoop.io.AbstractMapWritable.readFields(AbstractMapWritable.java:204) > at org.apache.hadoop.io.MapWritable.readFields(MapWritable.java:146) > at > org.apache.hama.graph.GraphJobMessage.readFields(GraphJobMessage.java:129) > at > org.apache.hama.bsp.BSPMessageBundle$1.next(BSPMessageBundle.java:108) > at > org.apache.hama.bsp.BSPMessageBundle$1.next(BSPMessageBundle.java:78) > at > org.apache.hama.bsp.LocalBSPRunner$LocalMessageManager.transfer(LocalBSPRunner.java:356) > 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:439) > 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:895) > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918) > at java.lang.Thread.run(Thread.java:662) > java.io.EOFException > at java.io.DataInputStream.readFully(DataInputStream.java:180) > at org.apache.hadoop.io.Text.readFields(Text.java:265) > at > org.apache.hama.graph.GraphJobMessage.readFields(GraphJobMessage.java:136) > at > org.apache.hama.bsp.BSPMessageBundle$1.next(BSPMessageBundle.java:108) > at > org.apache.hama.bsp.BSPMessageBundle$1.next(BSPMessageBundle.java:78) > at > org.apache.hama.bsp.LocalBSPRunner$LocalMessageManager.transfer(LocalBSPRunner.java:356) > 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:439) > 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:895) > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918) > at java.lang.Thread.run(Thread.java:662) > java.io.IOException: can't find class: testhamayoon.TestHamaYoon$MyWritable > because testhamayoon.TestHamaYoon$MyWritable > > at > org.apache.hadoop.io.AbstractMapWritable.readFields(AbstractMapWritable.java:204) > at org.apache.hadoop.io.MapWritable.readFields(MapWritable.java:146) > at > org.apache.hama.graph.GraphJobMessage.readFields(GraphJobMessage.java:129) > at > org.apache.hama.bsp.BSPMessageBundle$1.next(BSPMessageBundle.java:108) > at > org.apache.hama.bsp.BSPMessageBundle$1.next(BSPMessageBundle.java:78) > at > org.apache.hama.bsp.LocalBSPRunner$LocalMessageManager.transfer(LocalBSPRunner.java:356) > 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:439) > 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:895) > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918) > at java.lang.Thread.run(Thread.java:662) > java.io.EOFException > at java.io.DataInputStream.readFully(DataInputStream.java:180) > at org.apache.hadoop.io.Text.readFields(Text.java:265) > at > org.apache.hama.graph.GraphJobMessage.readFields(GraphJobMessage.java:136) > at > org.apache.hama.bsp.BSPMessageBundle$1.next(BSPMessageBundle.java:108) > at > org.apache.hama.bsp.BSPMessageBundle$1.next(BSPMessageBundle.java:78) > at > org.apache.hama.bsp.LocalBSPRunner$LocalMessageManager.transfer(LocalBSPRunner.java:356) > 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:439) > 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:895) > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918) > at java.lang.Thread.run(Thread.java:662) > 14/02/25 18:51:40 ERROR bsp.LocalBSPRunner: Exception during BSP execution! > > java.lang.UnsupportedOperationException: Unknown message type: > GraphJobMessage [flag=0, map=null, vertexId=, vertexValue=null] > at > org.apache.hama.graph.GraphJobRunner.parseMessages(GraphJobRunner.java:590) > at org.apache.hama.graph.GraphJobRunner.bsp(GraphJobRunner.java:136) > 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:439) > 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:895) > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918) > at java.lang.Thread.run(Thread.java:662) > 14/02/25 18:51:40 ERROR bsp.LocalBSPRunner: Exception during BSP execution! > > java.util.concurrent.ExecutionException: > java.lang.UnsupportedOperationException: Unknown message type: > GraphJobMessage [flag=0, map=null, vertexId=, vertexValue=null] > 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.UnsupportedOperationException: Unknown message type: > GraphJobMessage [flag=0, map=null, vertexId=, vertexValue=null] > at > org.apache.hama.graph.GraphJobRunner.parseMessages(GraphJobRunner.java:590) > at org.apache.hama.graph.GraphJobRunner.bsp(GraphJobRunner.java:136) > 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:439) > 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:895) > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918) > ... 1 more > 14/02/25 18:51:40 ERROR bsp.LocalBSPRunner: Exception during BSP execution! > org.apache.hama.bsp.sync.SyncException > at > org.apache.hama.bsp.LocalBSPRunner$LocalSyncClient.enterBarrier(LocalBSPRunner.java:445) > at > org.apache.hama.bsp.BSPPeerImpl.enterBarrier(BSPPeerImpl.java:430) > at org.apache.hama.bsp.BSPPeerImpl.sync(BSPPeerImpl.java:396) > at > org.apache.hama.graph.GraphJobRunner.doAggregationUpdates(GraphJobRunner.java:211) > at org.apache.hama.graph.GraphJobRunner.bsp(GraphJobRunner.java:138) > > 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:439) > 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:895) > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918) > at java.lang.Thread.run(Thread.java:662) > 14/02/25 18:51:43 INFO bsp.BSPJobClient: Current supersteps number: 1 > 14/02/25 18:51:43 INFO bsp.BSPJobClient: Job failed. > > > Quoting "Edward J. Yoon" <[email protected]>: > >> See http://people.apache.org/~edwardyoon/MyTest.txt >> >> On Tue, Feb 25, 2014 at 8:25 PM, <[email protected]> wrote: >>> >>> >>> I really can't find a solution, can you please send me a simple custom >>> message type of yours that is working so that I can clear some bug >>> possibilities out? >>> >>> Thanks. >>> >>> >>> >>> Quoting [email protected]: >>> >>>> Ok I will check again. I just found it strange to throw that kind of >>>> error >>>> without changing anything. >>>> >>>> >>>> >>>> Quoting "Edward J. Yoon" <[email protected]>: >>>> >>>>> Please see >>>>> >>>>> http://svn.apache.org/repos/asf/hama/trunk/examples/src/main/java/org/apache/hama/examples/PageRank.java >>>>> and check your program whether it is implemented correctly or not. >>>>> >>>>> I guess, it's not a problem of aggregator. It's a bug in your program. >>>>> >>>>> On Mon, Feb 24, 2014 at 6:50 PM, <[email protected]> wrote: >>>>>> >>>>>> >>>>>> This is the code. What changed and suddenly it throws the error? >>>>>> >>>>>> >>>>>> >>>>>> package corever2; >>>>>> import java.io.DataInput; >>>>>> import java.io.DataOutput; >>>>>> import java.io.IOException; >>>>>> import org.apache.hadoop.io.DoubleWritable; >>>>>> import org.apache.hadoop.io.IntWritable; >>>>>> import org.apache.hadoop.io.Text; >>>>>> import org.apache.hadoop.io.Writable; >>>>>> >>>>>> public class MessageCore implements Writable { >>>>>> >>>>>> private DoubleWritable type; >>>>>> private Text nodeID; >>>>>> private IntWritable degree; >>>>>> private IntWritable maxDegree; >>>>>> private IntWritable nodeCounter; >>>>>> >>>>>> public MessageCore() { >>>>>> type = new DoubleWritable(); >>>>>> nodeID = new Text(); >>>>>> degree = new IntWritable(); >>>>>> maxDegree = new IntWritable(); >>>>>> nodeCounter = new IntWritable(); >>>>>> } >>>>>> >>>>>> public MessageCore(DoubleWritable type, Text nodeID, IntWritable >>>>>> degree, >>>>>> IntWritable maxDegree, IntWritable nodeCounter) { >>>>>> this.type = type; >>>>>> this.nodeID = nodeID; >>>>>> this.degree = degree; >>>>>> this.maxDegree = maxDegree; >>>>>> this.nodeCounter = nodeCounter; >>>>>> } >>>>>> >>>>>> public MessageCore(DoubleWritable type, Text nodeID) { >>>>>> this.type = type; >>>>>> this.nodeID = nodeID; >>>>>> degree = new IntWritable(); >>>>>> maxDegree = new IntWritable(); >>>>>> nodeCounter = new IntWritable(); >>>>>> } >>>>>> >>>>>> public void setNodeCounter(IntWritable nodeCounter) { >>>>>> this.nodeCounter = nodeCounter; >>>>>> } >>>>>> >>>>>> public void setMaxDegree(IntWritable maxDegree) { >>>>>> this.maxDegree = maxDegree; >>>>>> } >>>>>> >>>>>> public void setType(DoubleWritable type) { >>>>>> this.type = type; >>>>>> } >>>>>> >>>>>> public void setNodeID(Text nodeID) { >>>>>> this.nodeID = nodeID; >>>>>> } >>>>>> >>>>>> public DoubleWritable getType() { >>>>>> return type; >>>>>> } >>>>>> >>>>>> public Text getNodeID() { >>>>>> return nodeID; >>>>>> } >>>>>> >>>>>> public IntWritable getDegree() { >>>>>> return degree; >>>>>> } >>>>>> >>>>>> public IntWritable getMaxDegree() { >>>>>> return maxDegree; >>>>>> } >>>>>> >>>>>> public IntWritable getNodeCounter() { >>>>>> return nodeCounter; >>>>>> } >>>>>> >>>>>> public void setDegree(IntWritable degree) { >>>>>> this.degree = degree; >>>>>> } >>>>>> >>>>>> @Override >>>>>> public String toString() { >>>>>> return nodeID + "\t" + degree; >>>>>> } >>>>>> >>>>>> @Override >>>>>> public void write(DataOutput d) throws IOException { >>>>>> type.write(d); >>>>>> nodeID.write(d); >>>>>> degree.write(d); >>>>>> maxDegree.write(d); >>>>>> nodeCounter.write(d); >>>>>> } >>>>>> >>>>>> @Override >>>>>> public void readFields(DataInput di) throws IOException { >>>>>> type.readFields(di); >>>>>> nodeID.readFields(di); >>>>>> degree.readFields(di); >>>>>> maxDegree.readFields(di); >>>>>> nodeCounter.readFields(di); >>>>>> >>>>>> } >>>>>> } >>>>>> >>>>>> >>>>>> >>>>>> Quoting "Edward J. Yoon" <[email protected]>: >>>>>> >>>>>>> Please attach your MessageCore. >>>>>>> >>>>>>> On Sun, Feb 23, 2014 at 11:37 PM, <[email protected]> wrote: >>>>>>>> >>>>>>>> >>>>>>>> >>>>>>>> Hello there, >>>>>>>> >>>>>>>> i downloaded hama-trunk a few days ago and till now I am trying to >>>>>>>> resolve >>>>>>>> the following problem that came up: >>>>>>>> >>>>>>>> My program runs without errors without aggregators. When I set the >>>>>>>> aggregator class to be used, I have the following error (which is >>>>>>>> like >>>>>>>> "cant >>>>>>>> find the message class" when the java file exists in the package!): >>>>>>>> >>>>>>>> corever2 is the package and MessageCore is the name of the class. >>>>>>>> >>>>>>>> java.io.IOException: can't find class: corever2.MessageCore because >>>>>>>> corever2.MessageCore >>>>>>>> at >>>>>>>> >>>>>>>> >>>>>>>> >>>>>>>> org.apache.hadoop.io.AbstractMapWritable.readFields(AbstractMapWritable.java:204) >>>>>>>> at >>>>>>>> org.apache.hadoop.io.MapWritable.readFields(MapWritable.java:146) >>>>>>>> at >>>>>>>> >>>>>>>> >>>>>>>> >>>>>>>> org.apache.hama.graph.GraphJobMessage.readFields(GraphJobMessage.java:129) >>>>>>>> at >>>>>>>> >>>>>>>> org.apache.hama.bsp.BSPMessageBundle$1.next(BSPMessageBundle.java:108) >>>>>>>> at >>>>>>>> >>>>>>>> org.apache.hama.bsp.BSPMessageBundle$1.next(BSPMessageBundle.java:78) >>>>>>>> at >>>>>>>> >>>>>>>> >>>>>>>> >>>>>>>> org.apache.hama.bsp.LocalBSPRunner$LocalMessageManager.transfer(LocalBSPRunner.java:356) >>>>>>>> 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:439) >>>>>>>> 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:895) >>>>>>>> at >>>>>>>> >>>>>>>> >>>>>>>> >>>>>>>> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918) >>>>>>>> at java.lang.Thread.run(Thread.java:662) >>>>>>>> java.io.EOFException >>>>>>>> at >>>>>>>> java.io.DataInputStream.readFully(DataInputStream.java:180) >>>>>>>> at org.apache.hadoop.io.Text.readFields(Text.java:265) >>>>>>>> at >>>>>>>> >>>>>>>> >>>>>>>> >>>>>>>> org.apache.hama.graph.GraphJobMessage.readFields(GraphJobMessage.java:136) >>>>>>>> at >>>>>>>> >>>>>>>> org.apache.hama.bsp.BSPMessageBundle$1.next(BSPMessageBundle.java:108) >>>>>>>> at >>>>>>>> >>>>>>>> org.apache.hama.bsp.BSPMessageBundle$1.next(BSPMessageBundle.java:78) >>>>>>>> at >>>>>>>> >>>>>>>> >>>>>>>> >>>>>>>> org.apache.hama.bsp.LocalBSPRunner$LocalMessageManager.transfer(LocalBSPRunner.java:356) >>>>>>>> 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:439) >>>>>>>> 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:895) >>>>>>>> at >>>>>>>> >>>>>>>> >>>>>>>> >>>>>>>> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918) >>>>>>>> at java.lang.Thread.run(Thread.java:662) >>>>>>>> 14/02/23 18:30:23 ERROR bsp.LocalBSPRunner: Exception during BSP >>>>>>>> execution! >>>>>>>> java.lang.UnsupportedOperationException: Unknown message type: >>>>>>>> GraphJobMessage [flag=0, map=null, vertexId=, vertexValue=null] >>>>>>>> at >>>>>>>> >>>>>>>> >>>>>>>> >>>>>>>> org.apache.hama.graph.GraphJobRunner.parseMessages(GraphJobRunner.java:590) >>>>>>>> at >>>>>>>> org.apache.hama.graph.GraphJobRunner.bsp(GraphJobRunner.java:136) >>>>>>>> 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:439) >>>>>>>> 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:895) >>>>>>>> at >>>>>>>> >>>>>>>> >>>>>>>> >>>>>>>> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918) >>>>>>>> at java.lang.Thread.run(Thread.java:662) >>>>>>>> 14/02/23 18:30:23 ERROR bsp.LocalBSPRunner: Exception during BSP >>>>>>>> execution! >>>>>>>> java.util.concurrent.ExecutionException: >>>>>>>> java.lang.UnsupportedOperationException: Unknown message type: >>>>>>>> GraphJobMessage [flag=0, map=null, vertexId=, vertexValue=null] >>>>>>>> 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.UnsupportedOperationException: Unknown message >>>>>>>> type: >>>>>>>> GraphJobMessage [flag=0, map=null, vertexId=, vertexValue=null] >>>>>>>> at >>>>>>>> >>>>>>>> >>>>>>>> >>>>>>>> org.apache.hama.graph.GraphJobRunner.parseMessages(GraphJobRunner.java:590) >>>>>>>> at >>>>>>>> org.apache.hama.graph.GraphJobRunner.bsp(GraphJobRunner.java:136) >>>>>>>> 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:439) >>>>>>>> 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:895) >>>>>>>> at >>>>>>>> >>>>>>>> >>>>>>>> >>>>>>>> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918) >>>>>>>> ... 1 more >>>>>>>> 14/02/23 18:30:25 INFO bsp.BSPJobClient: Current supersteps number: >>>>>>>> 1 >>>>>>>> 14/02/23 18:30:25 INFO bsp.BSPJobClient: Job failed. >>>>>>>> >>>>>>>> >>>>>>>> The only thing I managed to figure is that this comes up when the >>>>>>>> aggregators are enabled. >>>>>>>> >>>>>>>> Thank you. >>>>>>>> >>>>>>> >>>>>>> >>>>>>> >>>>>>> -- >>>>>>> Edward J. Yoon (@eddieyoon) >>>>>>> Chief Executive Officer >>>>>>> DataSayer, Inc. >>>>>> >>>>>> >>>>>> >>>>>> >>>>>> >>>>> >>>>> >>>>> >>>>> -- >>>>> Edward J. Yoon (@eddieyoon) >>>>> Chief Executive Officer >>>>> DataSayer, Inc. >>> >>> >>> >>> >>> >> >> >> >> -- >> Edward J. Yoon (@eddieyoon) >> Chief Executive Officer >> DataSayer, Inc. > > > >
-- Edward J. Yoon (@eddieyoon) Chief Executive Officer DataSayer, Inc.
