Skip to content

Commit 8d12e69

Browse files
committed
Fixes compilation error
1 parent c71ac6c commit 8d12e69

File tree

2 files changed

+2
-3
lines changed

2 files changed

+2
-3
lines changed

sql/core/src/main/scala/org/apache/spark/sql/sources/ddl.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -287,7 +287,7 @@ private[sql] object ResolvedDataSource {
287287
options)
288288
sqlContext.executePlan(
289289
InsertIntoFSBasedRelation(
290-
r.asInstanceOf[FSBasedRelation],
290+
r,
291291
data.logicalPlan,
292292
partitionColumns.toArray,
293293
mode)).toRdd

sql/hive/src/test/scala/org/apache/spark/sql/sources/SimpleTextRelation.scala

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,6 @@ import org.apache.hadoop.mapreduce.lib.output.{FileOutputFormat, TextOutputForma
2727
import org.apache.hadoop.mapreduce.{RecordWriter, TaskAttemptContext}
2828

2929
import org.apache.spark.rdd.RDD
30-
import org.apache.spark.sql.catalyst.CatalystTypeConverters
3130
import org.apache.spark.sql.catalyst.expressions.{Cast, Literal}
3231
import org.apache.spark.sql.types.{DataType, StructField, StructType}
3332
import org.apache.spark.sql.{Row, SQLContext}
@@ -40,7 +39,7 @@ class SimpleTextSource extends FSBasedRelationProvider {
4039
sqlContext: SQLContext,
4140
schema: Option[StructType],
4241
partitionColumns: Option[StructType],
43-
parameters: Map[String, String]): BaseRelation = {
42+
parameters: Map[String, String]): FSBasedRelation = {
4443
new SimpleTextRelation(
4544
Array(parameters("path")), schema,
4645
partitionColumns.getOrElse(StructType(Array.empty[StructField])), parameters)(sqlContext)

0 commit comments

Comments
 (0)