address comments

cloud-fan · cloud-fan · commit 2f24c10fdda9 · 2017-01-18T09:18:20.000+08:00
diff --git a/sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/HiveFileFormat.scala b/sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/HiveFileFormat.scala
@@ -46,7 +46,9 @@ class HiveFileFormat(fileSinkConf: FileSinkDesc) extends FileFormat {
   override def inferSchema(
       sparkSession: SparkSession,
       options: Map[String, String],
-      files: Seq[FileStatus]): Option[StructType] = None
+      files: Seq[FileStatus]): Option[StructType] = {
+    throw new UnsupportedOperationException(s"inferSchema is not supported for hive data source.")
+  }
 
   override def prepareWrite(
       sparkSession: SparkSession,
