Скорее всего, у ваших временных отметок в журнале нет "неправильного" часового пояса, но либо ваш искровой кластер был расположен в GMT, либо значение conf было установлено как:
spark.conf.set("spark.sql.session.timeZone", "GMT")
Измените эту строку явнов лондонский часовой пояс (BST?)
Или используйте необычную функцию from_utc_timestamp, которая позволяет вам указывать часовой пояс при преобразовании ts
. Также проверьте, указан ли ваш ts в миллисекундах, и установите -Duser.timezone вКонфигурация JVM spark.executor.extraJavaOptions