...
The default implementation of Apache Hama is org.apache.hama.bsp.message.HadoopMessageManagerImplHamaMessageManagerImpl
which uses Hadoop's RPC mechanisms.
...
Your implemenation can be set by the configuration values:
No Format |
---|
hama.messangermessenger.class |
Make sure this configuration is consistent on every host in every configuration. And make sure that the class has a public default constructure since it will be instantiated via reflection.