Merge pull request #154 from spotify/neville/avro

fix AvroCoder usage in scio-hdfs
spotify · May 26, 2016 · 192dea7 · 192dea7
2 parents dd44578 + 3ca1942
commit 192dea7
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/scio-hdfs/src/main/scala/com/spotify/scio/hdfs/package.scala b/scio-hdfs/src/main/scala/com/spotify/scio/hdfs/package.scala
@@ -96,7 +96,7 @@ package object hdfs {
       val coder: AvroCoder[T] = if (schema == null) {
         AvroCoder.of(ScioUtil.classOf[T])
       } else {
-        AvroCoder.of(schema).asInstanceOf[AvroCoder[T]]
+        AvroCoder.of(ScioUtil.classOf[T], schema)
       }
       val src = if (username != null) {
         new SimpleAuthAvroHadoopFileSource[T](path, coder, username)