Spark хранит неправильно в последний день месяца в MySQL - PullRequest
1 голос
/ 06 марта 2019

Я использую спарк, и моя задача - записать последний день месяца в 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 - это дата, которая не должна зависеть от часового пояса.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...