Github user rxin commented on a diff in the pull request:
https://github.com/apache/spark/pull/19250#discussion_r143122503
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/DataFrameWriter.scala ---
@@ -266,6 +267,10 @@ final class DataFrameWriter[T] private[sql](ds:
Dataset[T]) {
* @since 1.4.0
*/
def insertInto(tableName: String): Unit = {
+ extraOptions.get(TimestampTableTimeZone.TIMEZONE_PROPERTY).foreach {
tz =>
--- End diff --
we don't seem to be doing this type of validity check in general; otherwise
we'd need to add a lot more checks here.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
