[ 
https://issues.apache.org/jira/browse/HAMA-362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13015183#comment-13015183
 ] 

Thomas Jungblut commented on HAMA-362:
--------------------------------------

Okay this was obvious:

{noformat} 
java.io.IOException: Call to localhost/127.0.0.1:30005 failed on local 
exception: java.io.IOException: *Can't write: 
org.apache.hama.bsp.ByteMessage@716cb7 as class org.apache.hama.bsp.BSPMessage*
        at org.apache.hadoop.ipc.Client.wrapException(Client.java:775)
        at org.apache.hadoop.ipc.Client.call(Client.java:743)
        at org.apache.hadoop.ipc.RPC$Invoker.invoke(RPC.java:220)
        at $Proxy0.put(Unknown Source)
        at org.apache.hama.bsp.BSPPeer.sync(BSPPeer.java:196)
        at 
org.apache.hama.bsp.TestBSPPeer$BSPPeerThread.runTest(TestBSPPeer.java:132)
        at 
net.sourceforge.groboutils.junit.v1.TestRunnable.run(TestRunnable.java:154)
        at java.lang.Thread.run(Thread.java:662)
Caused by: java.io.IOException: Can't write: 
org.apache.hama.bsp.ByteMessage@716cb7 as class org.apache.hama.bsp.BSPMessage
        at 
org.apache.hadoop.io.ObjectWritable.writeObject(ObjectWritable.java:162)
        at org.apache.hadoop.ipc.RPC$Invocation.write(RPC.java:112)
        at org.apache.hadoop.ipc.Client$Connection.sendParam(Client.java:475)
        at org.apache.hadoop.ipc.Client.call(Client.java:721)
        ... 6 more
{noformat} 

> Design a new data structure for tag and message data of BSPMessage
> ------------------------------------------------------------------
>
>                 Key: HAMA-362
>                 URL: https://issues.apache.org/jira/browse/HAMA-362
>             Project: Hama
>          Issue Type: New Feature
>          Components: bsp
>    Affects Versions: 0.3.0
>            Reporter: Edward J. Yoon
>             Fix For: 0.3.0
>
>         Attachments: 362.patch
>
>
> The tag and message type are byte[]. However, I guess, the message of 
> BSPMessage (almost) will be a {adjacent, vector, .., etc} *list*.
> By supporting generic datatypes, it will be able to represent any data 
> structure and make easy-to-program.
> And, It should be compressible, writable, and flexible.

--
This message is automatically generated by JIRA.
For more information on JIRA, see: http://www.atlassian.com/software/jira

Reply via email to