Index: src/java/org/apache/hama/io/VectorWritable.java =================================================================== --- src/java/org/apache/hama/io/VectorWritable.java (revision 688720) +++ src/java/org/apache/hama/io/VectorWritable.java (working copy) @@ -160,7 +160,7 @@ sb.append(ioe.toString()); } } else { - sb.append(value); + sb.append(Bytes.toString(value)); } sb.append(")"); } @@ -173,7 +173,7 @@ * The inner class for an entry of row. * */ - public class Entries implements Map.Entry { + public static class Entries implements Map.Entry { private final byte[] column; private final Cell cell; Index: src/java/org/apache/hama/mapred/MatrixInputFormatBase.java =================================================================== --- src/java/org/apache/hama/mapred/MatrixInputFormatBase.java (revision 688720) +++ src/java/org/apache/hama/mapred/MatrixInputFormatBase.java (working copy) @@ -54,7 +54,7 @@ /** * Iterate over an HBase table data, return (Text, DenseVector) pairs */ - protected class TableRecordReader implements + protected static class TableRecordReader implements RecordReader { private byte[] startRow; private byte[] endRow; @@ -168,7 +168,6 @@ * @return true if there was more data * @throws IOException */ - @SuppressWarnings("unchecked") public boolean next(ImmutableBytesWritable key, DenseVector value) throws IOException { RowResult result = this.scanner.next(); @@ -189,8 +188,7 @@ * JobConf, Reporter) */ public RecordReader getRecordReader( - InputSplit split, @SuppressWarnings("unused") JobConf job, - @SuppressWarnings("unused") Reporter reporter) throws IOException { + InputSplit split, JobConf job, Reporter reporter) throws IOException { TableSplit tSplit = (TableSplit) split; TableRecordReader trr = this.tableRecordReader; // if no table record reader was provided use default