aboutsummaryrefslogtreecommitdiff
path: root/sql/catalyst
diff options
context:
space:
mode:
authorCheng Hao <hao.cheng@intel.com>2014-12-11 22:51:49 -0800
committerMichael Armbrust <michael@databricks.com>2014-12-11 22:51:49 -0800
commit0abbff286220bbcbbf28fbd80b8c5bf59ff37ce2 (patch)
treed820a4998585b6bce08431d090f02ab5993e5473 /sql/catalyst
parentcbb634ae69163ca7a8b5cb94c5fb17cb5c910cb1 (diff)
downloadspark-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.scala2
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(