Skip to content

Commit 43e041f

Browse files
committed
Revert back
1 parent 94ac716 commit 43e041f

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/HiveOptions.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -116,7 +116,7 @@ object HiveOptions {
116116
val tableProps = tableInfo.getProperties.asScala.toMap
117117
tableInfo.getOutputFileFormatClassName.toLowerCase match {
118118
case formatName if formatName.endsWith("parquetoutputformat") =>
119-
val compressionCodec = new ParquetOptions(tableProps, sqlConf).compressionCodec
119+
val compressionCodec = new ParquetOptions(tableProps, sqlConf).compressionCodecClassName
120120
Option((ParquetOutputFormat.COMPRESSION, compressionCodec))
121121
case formatName if formatName.endsWith("orcoutputformat") =>
122122
val compressionCodec = new OrcOptions(tableProps, sqlConf).compressionCodec

0 commit comments

Comments
 (0)