diff options
author | Cheng Hao <hao.cheng@intel.com> | 2014-12-11 22:51:49 -0800 |
---|---|---|
committer | Michael Armbrust <michael@databricks.com> | 2014-12-11 22:51:49 -0800 |
commit | 0abbff286220bbcbbf28fbd80b8c5bf59ff37ce2 (patch) | |
tree | d820a4998585b6bce08431d090f02ab5993e5473 /sql/catalyst | |
parent | cbb634ae69163ca7a8b5cb94c5fb17cb5c910cb1 (diff) | |
download | spark-0abbff286220bbcbbf28fbd80b8c5bf59ff37ce2.tar.gz spark-0abbff286220bbcbbf28fbd80b8c5bf59ff37ce2.tar.bz2 spark-0abbff286220bbcbbf28fbd80b8c5bf59ff37ce2.zip |
[SPARK-4825] [SQL] CTAS fails to resolve when created using saveAsTable
Fix bug when query like:
```
test("save join to table") {
val testData = sparkContext.parallelize(1 to 10).map(i => TestData(i, i.toString))
sql("CREATE TABLE test1 (key INT, value STRING)")
testData.insertInto("test1")
sql("CREATE TABLE test2 (key INT, value STRING)")
testData.insertInto("test2")
testData.insertInto("test2")
sql("SELECT COUNT(a.value) FROM test1 a JOIN test2 b ON a.key = b.key").saveAsTable("test")
checkAnswer(
table("test"),
sql("SELECT COUNT(a.value) FROM test1 a JOIN test2 b ON a.key = b.key").collect().toSeq)
}
```
Author: Cheng Hao <hao.cheng@intel.com>
Closes #3673 from chenghao-intel/spark_4825 and squashes the following commits:
e8cbd56 [Cheng Hao] alternate the pattern matching order for logical plan:CTAS
e004895 [Cheng Hao] fix bug
Diffstat (limited to 'sql/catalyst')
-rw-r--r-- | sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/basicOperators.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/basicOperators.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/basicOperators.scala index 00bdf108a8..64b8d45ebb 100644 --- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/basicOperators.scala +++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/basicOperators.scala @@ -121,7 +121,7 @@ case class CreateTableAsSelect[T]( allowExisting: Boolean, desc: Option[T] = None) extends UnaryNode { override def output = Seq.empty[Attribute] - override lazy val resolved = (databaseName != None && childrenResolved) + override lazy val resolved = databaseName != None && childrenResolved } case class WriteToFile( |