https://github.com/apache/spark
Revision 3772d9322cc751c0f7c1703b95023dd4527a0fac authored by gatorsmile on 10 December 2018, 06:57:20 UTC, committed by Wenchen Fan on 10 December 2018, 06:59:35 UTC
This is a  Spark 2.3 regression introduced in https://github.com/apache/spark/pull/20521. We should add the partition info for InsertIntoHiveTable in CreateHiveTableAsSelectCommand. Otherwise, we will hit the following error by running the newly added test case:

```
[info] - CTAS: INSERT a partitioned table using Hive serde *** FAILED *** (829 milliseconds)
[info]   org.apache.spark.SparkException: Requested partitioning does not match the tab1 table:
[info] Requested partitions:
[info] Table partitions: part
[info]   at org.apache.spark.sql.hive.execution.InsertIntoHiveTable.processInsert(InsertIntoHiveTable.scala:179)
[info]   at org.apache.spark.sql.hive.execution.InsertIntoHiveTable.run(InsertIntoHiveTable.scala:107)
```

Added a test case.

Closes #23255 from gatorsmile/fixCTAS.

Authored-by: gatorsmile <gatorsmile@gmail.com>
Signed-off-by: Wenchen Fan <wenchen@databricks.com>
(cherry picked from commit 3bc83de3cce86a06c275c86b547a99afd781761f)
Signed-off-by: Wenchen Fan <wenchen@databricks.com>
1 parent 1899dd2
History
Tip revision: 3772d9322cc751c0f7c1703b95023dd4527a0fac authored by gatorsmile on 10 December 2018, 06:57:20 UTC
[SPARK-26307][SQL] Fix CTAS when INSERT a partitioned table using Hive serde
Tip revision: 3772d93

README.md

back to top