解決Flink輸出日志中時間比當前時間晚8個小時的問題


    Flink安裝在CentOS7上,默認時間是UTC時間,查看Flink日志,發現輸出時間比當前時間晚8個小時。

    通過如下命令,調整成北京時間

cp /usr/share/zoneinfo/Asia/Shanghai /etc/localtime

   但是查看Flink輸出的日志時間格式,輸出時間仍然比當前時間晚8個小時!

   經過研究,以下操作,可以解決日志輸出時間比當前時間晚8小時的問題。

一、jobmanager輸出日志時間格式修改

   修改$FLINK_HOME/bin/jobmanager.sh中JAVA OPTS環境變量:

# Add JobManager-specific JVM options
export FLINK_ENV_JAVA_OPTS="${FLINK_ENV_JAVA_OPTS} ${FLINK_ENV_JAVA_OPTS_JM}"

改為:

# Add JobManager-specific JVM options
export FLINK_ENV_JAVA_OPTS="${FLINK_ENV_JAVA_OPTS} ${FLINK_ENV_JAVA_OPTS_JM} -Duser.timezone=GMT+08"

 

二、taskmanager輸出日志時間格式修改

 修改$FLINK_HOME/bin/taskmanager.sh中JAVA OPTS環境變量:

# Add TaskManager-specific JVM options

export FLINK_ENV_JAVA_OPTS="${FLINK_ENV_JAVA_OPTS} ${FLINK_ENV_JAVA_OPTS_TM}"

改為:

# Add TaskManager-specific JVM options

export FLINK_ENV_JAVA_OPTS="${FLINK_ENV_JAVA_OPTS} ${FLINK_ENV_JAVA_OPTS_TM} -Duser.timezone=GMT+08"

 

三、修改完上面的Shell腳本后,分別拷貝到其他節點, 重啟Flink集群


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM