From user-return-1223-apmail-hama-user-archive=hama.apache.org@hama.apache.org Sun Feb 23 14:38:39 2014 Return-Path: X-Original-To: apmail-hama-user-archive@www.apache.org Delivered-To: apmail-hama-user-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 2E54A10FBA for ; Sun, 23 Feb 2014 14:38:39 +0000 (UTC) Received: (qmail 33746 invoked by uid 500); 23 Feb 2014 14:38:39 -0000 Delivered-To: apmail-hama-user-archive@hama.apache.org Received: (qmail 33548 invoked by uid 500); 23 Feb 2014 14:38:31 -0000 Mailing-List: contact user-help@hama.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@hama.apache.org Delivered-To: mailing list user@hama.apache.org Received: (qmail 33529 invoked by uid 99); 23 Feb 2014 14:38:29 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Sun, 23 Feb 2014 14:38:29 +0000 X-ASF-Spam-Status: No, hits=-0.0 required=5.0 tests=SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: local policy) Received: from [155.207.1.51] (HELO hermes8.ccf.auth.gr) (155.207.1.51) by apache.org (qpsmtpd/0.29) with ESMTP; Sun, 23 Feb 2014 14:38:21 +0000 Received: from antigoni2 (antigoni2.ccf.auth.gr [155.207.1.114]) by hermes8.ccf.auth.gr (8.14.3/8.14.3/Debian-9.1ubuntu1) with ESMTP id s1NEbv0K028318 (version=TLSv1/SSLv3 cipher=DHE-RSA-AES256-SHA bits=256 verify=NOT) for ; Sun, 23 Feb 2014 16:37:58 +0200 Received: from dsl-aauz65.dyn.edudsl.gr (dsl-aauz65.dyn.edudsl.gr [37.32.191.141]) by webmail.auth.gr (Horde Framework) with HTTP; Sun, 23 Feb 2014 16:37:57 +0200 Date: Sun, 23 Feb 2014 16:37:57 +0200 Message-ID: <20140223163757.Horde.ASMviOdWydaih9qDTFSG2g1@webmail.auth.gr> From: ikapoura@csd.auth.gr To: user Subject: Aggregator problem User-Agent: Internet Messaging Program (IMP) H5 (6.1.5) Content-Type: text/plain; charset=UTF-8; format=flowed; DelSp=Yes MIME-Version: 1.0 Content-Disposition: inline X-Virus-Scanned: clamav-milter 0.97.8 at hermes8 X-Virus-Status: Clean X-Virus-Checked: Checked by ClamAV on apache.org 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.