search

itinycheng / flink-connector-clickhouse

Flink SQL connector for ClickHouse. Support ClickHouseCatalog and read/write primary data, maps, arrays to clickhouse.
Apache License 2.0
373 stars 156 forks source link

[Bug]: 发现除了insert，update和delete操作都无法正常同步 #146

Closed wslzq closed 4 months ago

wslzq commented 4 months ago

What happened?

源库： mysql> select * from dict_city where guid=344; +------+---------------+-----------+--------------------+----------+-----------+-----------------------+ | GUID | PROVINCE_GUID | CITY_NAME | CITY_TYPE | AREACODE | FOR_SHORT | XINGZHENG_QUHUA_DAIMA | +------+---------------+-----------+--------------------+----------+-----------+-----------------------+ | 344 | 40 | 台湾 | 其它城市企业 | 1002 | 台湾 | NULL | +------+---------------+-----------+--------------------+----------+-----------+-----------------------+ 1 row in set (0.00 sec)

clickhouse： ┌─GUID─┬─PROVINCE_GUID─┬─CITY_NAME─┬─CITY_TYPE────┬─AREACODE─┬─FOR_SHORT─┬─XINGZHENG_QUHUA_DAIMA─┐

  1. │ 344 │ 34 │ 马六甲 │ 其它城市企业 │ 1002 │ 马六甲 │ │ └──────┴───────────────┴───────────┴──────────────┴──────────┴───────────┴───────────────────────┘

1 row in set. Elapsed: 0.005 sec.

Affects Versions

flink 1.18

What are you seeing the problem on?

Connector Connection

How to reproduce

No response

Relevant log output

No response

Anything else

No response

Are you willing to submit a PR?

Code of Conduct