【发布时间】:2021-03-22 05:11:32
【问题描述】:
我正在通过 spark 将数据加载到镶木地板。
dataFrame.write.parquet(path)
我的数据在写入 parquet 时有一个时间戳列,它实际上是将时间戳转换为 UTC 时区,然后存储。
实际时间 -------- 2020-10-21 00:00:00.000
UTC时间--------- 2020-10-21T05:30:00.000+05:30
我看到 spark conf 设置为 UTC 时区。spark.sql.session.timeZone
有什么办法可以关闭这种转换?
我想按原样加载时间戳而不将其转换为任何其他时区。我该怎么做?
【问题讨论】:
-
你设置 spark.session.timezone 了吗?
-
在我的集群中它设置为 UTC
-
作为替代选项,您可以将其存储为
long。
标签: scala apache-spark timestamp parquet timestamp-with-timezone