Я использую спарк, и моя задача - записать последний день месяца в mysql.Но у меня были некоторые проблемы с часовым поясом.Моя система находится в часовом поясе UTC + 8, а mysql - в часовом поясе UTC + 0.
Код искры довольно прост
val randomDay = args(0)
val temp = spark.sql(s"""select last_day('$randomDay') as lastday from .....""")
Но когда я посмотрел наMySQL таблица, он показывает 2019/3/30, который является выходным.Я попробовал temp.show()
, и он показывает правильную дату 2019/3/31.
Я знаю, что это как-то связано с часовым поясом, но я не знаю, как это исправить.Кроме того, тип столбца таблицы MySQL - это дата, которая не должна зависеть от часового пояса.