File tree Expand file tree Collapse file tree 1 file changed +0
-2
lines changed
sql/hive/src/main/scala/org/apache/spark/sql/hive/orc Expand file tree Collapse file tree 1 file changed +0
-2
lines changed Original file line number Diff line number Diff line change @@ -72,7 +72,6 @@ class OrcFileFormat extends FileFormat with DataSourceRegister with Serializable
7272 job : Job ,
7373 options : Map [String , String ],
7474 dataSchema : StructType ): OutputWriterFactory = {
75- DataSourceUtils .verifyWriteSchema(this , dataSchema)
7675
7776 val orcOptions = new OrcOptions (options, sparkSession.sessionState.conf)
7877
@@ -123,7 +122,6 @@ class OrcFileFormat extends FileFormat with DataSourceRegister with Serializable
123122 filters : Seq [Filter ],
124123 options : Map [String , String ],
125124 hadoopConf : Configuration ): (PartitionedFile ) => Iterator [InternalRow ] = {
126- DataSourceUtils .verifyReadSchema(this , dataSchema)
127125
128126 if (sparkSession.sessionState.conf.orcFilterPushDown) {
129127 // Sets pushed predicates
You can’t perform that action at this time.
0 commit comments