在Flink-SQL中有一個系統函數：?CURRENT_DATE，沒錯，都知道這個表示的是當日的日期。

在阿里云的Blink平臺中，CURRENT_DATE很友好的把他顯示的是今天。

在Flink社區版中，這個CURRENT_DATE是指的UTC時間，太自信了連社區官網都不看，結果每天的指標跑出來都是錯的，如果你早晨8點前在代碼中執行：
?

select CURRENT_DATE

它顯示的會是昨天。UTC時間比我們東八區北京時間慢了8小時。

如果在項目中使用了CURRENT_DATE，你會發現指標在跨天的時候總是不會清零。

?

如果你想用北京時間的今天：CAST(TO_DATE(CAST(LOCALTIMESTAMP AS VARCHAR)) AS VARCHAR)

簡單點的：直接寫一個udf然后把它注冊上，比如命名成：BEIJING_DATE

?

總結

以上是生活随笔為你收集整理的Flink-1.11.1 Flink-SQL日期函数的一个坑的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。