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
   }