Skip to content
Browse files

Fix serialization test.

  • Loading branch information...
1 parent fa7e89b commit 2500cfc57b6065fdbecc40b25d52aa0283230efc @azymnis azymnis committed Apr 18, 2012
Showing with 1 addition and 1 deletion.
  1. +1 −1 src/test/scala/com/twitter/scalding/KryoTest.scala
View
2 src/test/scala/com/twitter/scalding/KryoTest.scala
@@ -19,7 +19,7 @@ class KryoTest extends Specification {
def serObj[T <: AnyRef](in : T) = {
val khs = new KryoHadoopSerialization
khs.accept(in.getClass)
- val ks = khs.getSerializer(in.getClass.asInstanceOf[Class[T]])
+ val ks = khs.getSerializer(in.getClass.asInstanceOf[Class[AnyRef]])
val out = new BOS
ks.open(out)
ks.serialize(in)

0 comments on commit 2500cfc

Please sign in to comment.
Something went wrong with that request. Please try again.