原文:【Flink SQL】Unable to convert to TimestampData from unexpected value of type java.lang.Long

需求 需要將Kafka的數據導入到Apache Druid,而Apache Druid的Ingestion時區是默認UTC 的。 不能使用如下時間格式: : : , 會被當成 T : : Z 。 總結 MYSQL CDC source 必須是timestamp,不能是timestamp ltz,否則Flink作業啟動后,CDC的connector報錯。 MYSQL CDC source serve ...

2021-09-28 20:02 0 96 推薦指數:

查看詳情

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