File tree Expand file tree Collapse file tree 1 file changed +3
-2
lines changed
sql/hive/src/main/scala/org/apache/spark/sql/hive/execution Expand file tree Collapse file tree 1 file changed +3
-2
lines changed Original file line number Diff line number Diff line change @@ -141,7 +141,7 @@ class HiveSqlAstBuilder extends SparkSqlAstBuilder {
141
141
if (ctx.storageHandler == null ) {
142
142
typedVisit[CatalogStorageFormat ](ctx.fileFormat)
143
143
} else {
144
- typedVisit[ CatalogStorageFormat ] (ctx.storageHandler)
144
+ visitStorageHandler (ctx.storageHandler)
145
145
}
146
146
}
147
147
@@ -403,7 +403,8 @@ class HiveSqlAstBuilder extends SparkSqlAstBuilder {
403
403
/**
404
404
* Storage Handlers are currently not supported in the statements we support (CTAS).
405
405
*/
406
- override def visitStorageHandler (ctx : StorageHandlerContext ): AnyRef = withOrigin(ctx) {
406
+ override def visitStorageHandler (
407
+ ctx : StorageHandlerContext ): CatalogStorageFormat = withOrigin(ctx) {
407
408
throw new ParseException (" Storage Handlers are currently unsupported." , ctx)
408
409
}
409
410
You can’t perform that action at this time.
0 commit comments