Skip to content

Commit

Permalink
quotes around property name
Browse files Browse the repository at this point in the history
  • Loading branch information
squito committed Sep 19, 2017
1 parent 74a9905 commit 515b38b
Show file tree
Hide file tree
Showing 2 changed files with 9 additions and 8 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -262,13 +262,14 @@ abstract class BaseTimestampTableTimeZoneSuite extends SparkPlanTest with SQLTes
// Finally, try changing the tbl timezone. This destroys integrity
// of the existing data, but at this point we're just checking we can change
// the metadata
spark.sql(s"""ALTER TABLE $tblName SET TBLPROPERTIES ($key="America/Los_Angeles")""")
spark.sql(
s"""ALTER TABLE $tblName SET TBLPROPERTIES ("$key"="America/Los_Angeles")""")
checkHasTz(spark, tblName, Some("America/Los_Angeles"))

spark.sql(s"""ALTER TABLE $tblName UNSET TBLPROPERTIES ($key)""")
spark.sql(s"""ALTER TABLE $tblName UNSET TBLPROPERTIES ("$key")""")
checkHasTz(spark, tblName, None)

spark.sql(s"""ALTER TABLE $tblName SET TBLPROPERTIES ($key="UTC")""")
spark.sql(s"""ALTER TABLE $tblName SET TBLPROPERTIES ("$key"="UTC")""")
checkHasTz(spark, tblName, Some("UTC"))
}
}
Expand Down Expand Up @@ -307,7 +308,7 @@ abstract class BaseTimestampTableTimeZoneSuite extends SparkPlanTest with SQLTes

createAndSave.createAndSave(data.toDF(), "bad_tz_table", None, "parquet")
hasBadTzException {
spark.sql(s"""ALTER TABLE bad_tz_table SET TBLPROPERTIES($key="$badVal")""")
spark.sql(s"""ALTER TABLE bad_tz_table SET TBLPROPERTIES("$key"="$badVal")""")
}
}
}
Expand Down Expand Up @@ -336,14 +337,14 @@ abstract class BaseTimestampTableTimeZoneSuite extends SparkPlanTest with SQLTes
withView("view_with_tz") {
val exc1 = intercept[AnalysisException]{
spark.sql(s"""CREATE VIEW view_with_tz
| TBLPROPERTIES ($key="UTC")
| TBLPROPERTIES ("$key"="UTC")
| AS SELECT * FROM ok_table
""".stripMargin)
}
assert(exc1.getMessage.contains("Timezone cannot be set for view"))
spark.sql("CREATE VIEW view_with_tz AS SELECT * FROM ok_table")
val exc2 = intercept[AnalysisException]{
spark.sql(s"""ALTER VIEW view_with_tz SET TBLPROPERTIES($key="UTC")""")
spark.sql(s"""ALTER VIEW view_with_tz SET TBLPROPERTIES("$key"="UTC")""")
}
assert(exc2.getMessage.contains("Timezone cannot be set for view"))
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -39,7 +39,7 @@ class HiveTimestampTableTimeZoneSuite extends BaseTimestampTableTimeZoneSuite
format: String): Boolean = {
if (format == "parquet") {
val tblProperties = tzOpt.map { tz =>
s"""TBLPROPERTIES (${TimestampTableTimeZone.TIMEZONE_PROPERTY}="$tz")"""
s"""TBLPROPERTIES ("${TimestampTableTimeZone.TIMEZONE_PROPERTY}"="$tz")"""
}.getOrElse("")
spark.sql(
s"""CREATE TABLE $table (
Expand All @@ -65,7 +65,7 @@ class HiveTimestampTableTimeZoneSuite extends BaseTimestampTableTimeZoneSuite
destFormat: String): Boolean = {
if (destFormat == "parquet") {
val tblProperties = destTz.map { tz =>
s"""TBLPROPERTIES (${TimestampTableTimeZone.TIMEZONE_PROPERTY}="$tz")"""
s"""TBLPROPERTIES ("${TimestampTableTimeZone.TIMEZONE_PROPERTY}"="$tz")"""
}.getOrElse("")
// this isn't just a "ctas" sql statement b/c that doesn't let us specify the table tz
spark.sql(
Expand Down

0 comments on commit 515b38b

Please sign in to comment.