Casts to OutputCommitter rather than FileOutputCommtter

liancheng · May 13, 2015 · 6063f87 · 6063f87
1 parent bfd1cf0
commit 6063f87
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/sources/commands.scala b/sql/core/src/main/scala/org/apache/spark/sql/sources/commands.scala
@@ -294,7 +294,7 @@ private[sql] abstract class BaseWriterContainer(
 
   private def newOutputCommitter(context: TaskAttemptContext): OutputCommitter = {
     val committerClass = context.getConfiguration.getClass(
-      "mapred.output.committer.class", null, classOf[FileOutputCommitter])
+      "mapred.output.committer.class", null, classOf[OutputCommitter])
 
     Option(committerClass).map { clazz =>
       val ctor = clazz.getDeclaredConstructor(classOf[Path], classOf[TaskAttemptContext])