Skip to content

Commit 1620079

Browse files
committed
Revert "remove hive parquet bundle"
This reverts commit 41ebc5f. Conflicts: sql/hive/src/main/scala/org/apache/spark/sql/hive/parquet/FakeParquetSerDe.scala
1 parent cc30430 commit 1620079

File tree

1 file changed

+8
-2
lines changed

1 file changed

+8
-2
lines changed

sql/hive/src/test/scala/org/apache/spark/sql/parquet/ParquetMetastoreSuite.scala

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -63,7 +63,10 @@ class ParquetMetastoreSuite extends QueryTest with BeforeAndAfterAll {
6363
stringField STRING
6464
)
6565
PARTITIONED BY (p int)
66-
ROW FORMAT SERDE 'org.apache.spark.sql.hive.parquet.FakeParquetSerDe'
66+
ROW FORMAT SERDE 'org.apache.hadoop.hive.ql.io.parquet.serde.ParquetHiveSerDe'
67+
STORED AS
68+
INPUTFORMAT 'org.apache.hadoop.hive.ql.io.parquet.MapredParquetInputFormat'
69+
OUTPUTFORMAT 'org.apache.hadoop.hive.ql.io.parquet.MapredParquetOutputFormat'
6770
location '${partitionedTableDir.getCanonicalPath}'
6871
""")
6972

@@ -73,7 +76,10 @@ class ParquetMetastoreSuite extends QueryTest with BeforeAndAfterAll {
7376
intField INT,
7477
stringField STRING
7578
)
76-
ROW FORMAT SERDE 'org.apache.spark.sql.hive.parquet.FakeParquetSerDe'
79+
ROW FORMAT SERDE 'org.apache.hadoop.hive.ql.io.parquet.serde.ParquetHiveSerDe'
80+
STORED AS
81+
INPUTFORMAT 'org.apache.hadoop.hive.ql.io.parquet.MapredParquetInputFormat'
82+
OUTPUTFORMAT 'org.apache.hadoop.hive.ql.io.parquet.MapredParquetOutputFormat'
7783
location '${new File(partitionedTableDir, "p=1").getCanonicalPath}'
7884
""")
7985

0 commit comments

Comments
 (0)