EXP-476. kiji-express should pass unit tests against cdh5.0.3

issue: https://jira.kiji.org/browse/EXP-476 review: https://review.kiji.org/r/2142
kijiproject · Aug 23, 2014 · e7b1fce · e7b1fce
1 parent da02340
commit e7b1fce
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...press/src/main/scala/org/kiji/express/flow/framework/serialization/ResultSerializer.scala b/...press/src/main/scala/org/kiji/express/flow/framework/serialization/ResultSerializer.scala
@@ -35,12 +35,12 @@ import org.apache.hadoop.hbase.protobuf.generated.ClientProtos
 class ResultSerializer extends Serializer[Result] {
   override def write(kryo: Kryo, output: Output, result: Result): Unit = {
     val protoResult: ClientProtos.Result = ProtobufUtil.toResult(result)
-    kryo.writeClassAndObject(output, protoResult)
+    protoResult.writeTo(output)
   }
 
   override def read(kryo: Kryo, input: Input, clazz: Class[Result]): Result = {
     val protoResult: ClientProtos.Result =
-      kryo.readClassAndObject(input).asInstanceOf[ClientProtos.Result]
+      ClientProtos.Result.parseFrom(input)
     val result: Result = ProtobufUtil.toResult(protoResult)
     result
   }