You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by we...@apache.org on 2016/09/05 03:17:53 UTC
spark git commit: [SPARK-17391][TEST][2.0] Fix Two Test Failures
After Backport
Repository: spark
Updated Branches:
refs/heads/branch-2.0 704215d30 -> e387c8ba8
[SPARK-17391][TEST][2.0] Fix Two Test Failures After Backport
### What changes were proposed in this pull request?
In the latest branch 2.0, we have two test case failure due to backport.
- test("ALTER VIEW AS should keep the previous table properties, comment, create_time, etc.")
- test("SPARK-6212: The EXPLAIN output of CTAS only shows the analyzed plan")
### How was this patch tested?
N/A
Author: gatorsmile <ga...@gmail.com>
Closes #14951 from gatorsmile/fixTestFailure.
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/e387c8ba
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/e387c8ba
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/e387c8ba
Branch: refs/heads/branch-2.0
Commit: e387c8ba86f89115eb2eabac070c215f451c5f0f
Parents: 704215d
Author: gatorsmile <ga...@gmail.com>
Authored: Mon Sep 5 11:17:37 2016 +0800
Committer: Wenchen Fan <we...@databricks.com>
Committed: Mon Sep 5 11:17:37 2016 +0800
----------------------------------------------------------------------
.../org/apache/spark/sql/hive/execution/HiveExplainSuite.scala | 6 +++---
.../org/apache/spark/sql/hive/execution/SQLViewSuite.scala | 4 ++--
2 files changed, 5 insertions(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/e387c8ba/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/HiveExplainSuite.scala
----------------------------------------------------------------------
diff --git a/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/HiveExplainSuite.scala b/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/HiveExplainSuite.scala
index 98afd99..ec3328c 100644
--- a/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/HiveExplainSuite.scala
+++ b/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/HiveExplainSuite.scala
@@ -77,7 +77,7 @@ class HiveExplainSuite extends QueryTest with SQLTestUtils with TestHiveSingleto
"src")
}
- test("SPARK-6212: The EXPLAIN output of CTAS only shows the analyzed plan") {
+ test("SPARK-17230: The EXPLAIN output of CTAS only shows the analyzed plan") {
withTempView("jt") {
val rdd = sparkContext.parallelize((1 to 10).map(i => s"""{"a":$i, "b":"str$i"}"""))
spark.read.json(rdd).createOrReplaceTempView("jt")
@@ -98,8 +98,8 @@ class HiveExplainSuite extends QueryTest with SQLTestUtils with TestHiveSingleto
}
val physicalIndex = outputs.indexOf("== Physical Plan ==")
- assert(!outputs.substring(physicalIndex).contains("Subquery"),
- "Physical Plan should not contain Subquery since it's eliminated by optimizer")
+ assert(outputs.substring(physicalIndex).contains("SubqueryAlias"),
+ "Physical Plan should contain SubqueryAlias since the query should not be optimized")
}
}
http://git-wip-us.apache.org/repos/asf/spark/blob/e387c8ba/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/SQLViewSuite.scala
----------------------------------------------------------------------
diff --git a/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/SQLViewSuite.scala b/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/SQLViewSuite.scala
index c6eeb8a..cf63537 100644
--- a/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/SQLViewSuite.scala
+++ b/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/SQLViewSuite.scala
@@ -232,12 +232,12 @@ class SQLViewSuite extends QueryTest with SQLTestUtils with TestHiveSingleton {
val catalog = spark.sessionState.catalog
val viewMeta = catalog.getTableMetadata(TableIdentifier("test_view"))
- assert(viewMeta.properties("comment") == "test")
+ assert(viewMeta.comment == Some("test"))
assert(viewMeta.properties("key") == "a")
sql("ALTER VIEW test_view AS SELECT 3 AS i, 4 AS j")
val updatedViewMeta = catalog.getTableMetadata(TableIdentifier("test_view"))
- assert(updatedViewMeta.properties("comment") == "test")
+ assert(updatedViewMeta.comment == Some("test"))
assert(updatedViewMeta.properties("key") == "a")
assert(updatedViewMeta.createTime == viewMeta.createTime)
// The view should be updated.
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org