You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@hama.apache.org by "Edward J. Yoon" <ed...@apache.org> on 2014/02/06 11:44:40 UTC

Bug in SemiClustering example

SemiClustering unit test passes even though I delete some code in
write() method. This means that it doesn't work on distributed
environment. Implementation accesses object in memory like threaded
program.

Who's willing to volunteer for this bug?

----
  public void write(DataOutput out) throws IOException {
    out.writeUTF(semiClusterId);
    out.writeDouble(semiClusterScore);

    if (this.semiClusterVertexList == null) {
      out.writeBoolean(false);
    } else {
      out.writeBoolean(true);
      out.writeInt(semiClusterVertexList.size());
      /*
      System.out.println(semiClusterVertexList.size());
      for (Vertex<Text, DoubleWritable, SemiClusterMessage> v :
semiClusterVertexList) {
        System.out.println(v.toString());
        v.write(out);
      }
      */
    }
    out.writeInt(semiClusterContainThis.size());

    for (SemiClusterDetails semiClusterContainThi : semiClusterContainThis)
      semiClusterContainThi.write(out);
  }


-- 
Best Regards, Edward J. Yoon
@eddieyoon