我在spark scala中有下面的代码,
val talinnTimestamp = from_utc_timestamp(to_utc_timestamp(from_unixtime(col("my_time") / 1000, "yyyy-MM-dd HH:mm:ss"), "Europe/Stockholm"), "Europe/Tallinn")
myDf
.withColumn("hour", date_format(talinnTimestamp, "HH").cast(IntegerType))
当我经过的时候 my_time = "1576493621006"
在上面的代码中,本地生成返回 hour = 12
但同样的代码返回 hour = 11
在Jenkins建造期间。
这可能是因为时区不同?
如何在本地和服务器上成功地通过测试用例?
暂无答案!
目前还没有任何答案,快来回答吧!