You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by gu...@apache.org on 2018/11/17 10:18:46 UTC
spark git commit: [MINOR][SQL] Fix typo in CTAS plan database string
Repository: spark
Updated Branches:
refs/heads/master 23cd0e6e9 -> b538c442c
[MINOR][SQL] Fix typo in CTAS plan database string
## What changes were proposed in this pull request?
Since [Spark 1.6.0](https://github.com/apache/spark/commit/56d7da14ab8f89bf4f303b27f51fd22d23967ffb#diff-6f38a103058a6e233b7ad80718452387R96), there was a redundant '}' character in CTAS string plan's database argument string; `default}`. This PR aims to fix it.
**BEFORE**
```scala
scala> sc.version
res1: String = 1.6.0
scala> sql("create table t as select 1").explain
== Physical Plan ==
ExecutedCommand CreateTableAsSelect [Database:default}, TableName: t, InsertIntoHiveTable]
+- Project [1 AS _c0#3]
+- OneRowRelation$
```
**AFTER**
```scala
scala> sql("create table t as select 1").explain
== Physical Plan ==
Execute CreateHiveTableAsSelectCommand CreateHiveTableAsSelectCommand [Database:default, TableName: t, InsertIntoHiveTable]
+- *(1) Project [1 AS 1#4]
+- Scan OneRowRelation[]
```
## How was this patch tested?
Manual.
Closes #23064 from dongjoon-hyun/SPARK-FIX.
Authored-by: Dongjoon Hyun <do...@apache.org>
Signed-off-by: hyukjinkwon <gu...@apache.org>
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/b538c442
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/b538c442
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/b538c442
Branch: refs/heads/master
Commit: b538c442cb3982cc4c3aac812a7d4764209dfbb7
Parents: 23cd0e6
Author: Dongjoon Hyun <do...@apache.org>
Authored: Sat Nov 17 18:18:41 2018 +0800
Committer: hyukjinkwon <gu...@apache.org>
Committed: Sat Nov 17 18:18:41 2018 +0800
----------------------------------------------------------------------
.../spark/sql/hive/execution/CreateHiveTableAsSelectCommand.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/b538c442/sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/CreateHiveTableAsSelectCommand.scala
----------------------------------------------------------------------
diff --git a/sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/CreateHiveTableAsSelectCommand.scala b/sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/CreateHiveTableAsSelectCommand.scala
index aa573b5..630bea5 100644
--- a/sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/CreateHiveTableAsSelectCommand.scala
+++ b/sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/CreateHiveTableAsSelectCommand.scala
@@ -96,7 +96,7 @@ case class CreateHiveTableAsSelectCommand(
}
override def argString: String = {
- s"[Database:${tableDesc.database}}, " +
+ s"[Database:${tableDesc.database}, " +
s"TableName: ${tableDesc.identifier.table}, " +
s"InsertIntoHiveTable]"
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org