我的sparkDataframe将timestamp作为字段之一,我需要将这个timestamp值保存在特定的时区(比如gmt-7:00)。jvm的默认时区是ist,在将dataframe保存到数据库时,时间戳值被转换为ist。
一种可能的解决方案是在保存Dataframe之前将jvm默认时区更新为gmt-7:00。从我这里起作用。
不过,还有一个建议的解决方案,那就是将spark conf属性spark.sql.session.timezone设置为必需的时区(在我的示例中是gmt-7:00)。在创建sparksession之前,我将这个属性添加到conf中,但是时间戳仍然保存在jvm默认时区中。有什么问题吗?
暂无答案!
目前还没有任何答案,快来回答吧!