From e7b1fce89a5ca46d36206c7ad6c8683d779d6dd2 Mon Sep 17 00:00:00 2001 From: Daisy Zhou Date: Fri, 15 Aug 2014 17:54:59 -0700 Subject: [PATCH] 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 --- .../flow/framework/serialization/ResultSerializer.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/kiji-express/src/main/scala/org/kiji/express/flow/framework/serialization/ResultSerializer.scala b/kiji-express/src/main/scala/org/kiji/express/flow/framework/serialization/ResultSerializer.scala index 9c6a99d8..8501d1b1 100644 --- a/kiji-express/src/main/scala/org/kiji/express/flow/framework/serialization/ResultSerializer.scala +++ b/kiji-express/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 }