日韩无码专区无码一级三级片|91人人爱网站中日韩无码电影|厨房大战丰满熟妇|AV高清无码在线免费观看|另类AV日韩少妇熟女|中文日本大黄一级黄色片|色情在线视频免费|亚洲成人特黄a片|黄片wwwav色图欧美|欧亚乱色一区二区三区

Flink CDC報錯可能是因為binlog格式不兼容，建議檢查binlog格式并修改為Flink支持的格式。

報錯信息：

創(chuàng)新互聯(lián)專業(yè)為企業(yè)提供莆田網(wǎng)站建設(shè)、莆田做網(wǎng)站、莆田網(wǎng)站設(shè)計、莆田網(wǎng)站制作等企業(yè)網(wǎng)站建設(shè)、網(wǎng)頁設(shè)計與制作、莆田企業(yè)網(wǎng)站模板建站服務(wù)，十余年莆田做網(wǎng)站經(jīng)驗，不只是建網(wǎng)站，更提供有價值的思路和整體網(wǎng)絡(luò)服務(wù)。

org.apache.flink.table.api.ValidationException: The binlog reader does not support the timestamp type of the changelog table.

這個錯誤表示Flink CDC在讀取binlog時，不支持changelog表的timestamp類型，為了解決這個問題，你可以嘗試以下方法：

1、更改changelog表的timestamp類型

2、不使用binlog作為數(shù)據(jù)源

3、使用其他支持timestamp類型的binlog reader

下面詳細(xì)介紹這三種方法：

更改changelog表的timestamp類型

1、修改changelog表的結(jié)構(gòu)，將timestamp字段的類型更改為Flink CDC支持的類型，TIMESTAMP(3) NOT NULL。

2、重新創(chuàng)建changelog表。

3、重啟Flink作業(yè)。

不使用binlog作為數(shù)據(jù)源

1、選擇其他數(shù)據(jù)源，Kafka、MySQL等。

2、修改Flink作業(yè)的代碼，使用新的數(shù)據(jù)源。

3、啟動Flink作業(yè)。

使用其他支持timestamp類型的binlog reader

1、尋找其他支持timestamp類型的binlog reader，Debezium。

2、下載并配置Debezium。

3、修改Flink作業(yè)的代碼，使用Debezium作為binlog reader。

4、啟動Flink作業(yè)。

新聞名稱：FlinkCDC里這個報錯意思很明確，但不想改binlog
網(wǎng)站地址：http://www.5511xx.com/article/dhcceog.html