aadant

We should be able to override the schema using a yaml file - data type mapping - default table settings - default type conversion - choice between LowCardinality versus String...

Support all datatypes in clickhouse_loader.py (ANTLR parser)

1

Example JSON we should support this https://github.com/Altinity/clickhouse-sink-connector/blob/develop/sink-connector/tests/data_types.sql

Test support for LOAD DATA

1

Not sure how Debezium is handling that ... https://dev.mysql.com/doc/refman/8.0/en/load-data.html

gh-ost is a tool that is a "swiss army knife" for schema changes https://github.com/github/gh-ost The sink connector should support a gh-ost running on the MySQL side without data loss. It...

Deadlock when connection try to disconnect

6

``` "blc-fpif1-txnrepodbl1:3306" #31833 prio=5 os_prio=0 cpu=3676437.42ms elapsed=146955.63s tid=0x00007fe9bc001800 nid=0x7e58 runnable [0x00007feb830d3000] java.lang.Thread.State: RUNNABLE at java.net.SocketOutputStream.socketWrite0([email protected]/Native Method) at java.net.SocketOutputStream.socketWrite([email protected]/SocketOutputStream.java:110) at java.net.SocketOutputStream.write([email protected]/SocketOutputStream.java:150) at sun.security.ssl.SSLSocketOutputRecord.flush([email protected]/SSLSocketOutputRecord.java:271) at sun.security.ssl.OutputRecord.changeWriteCiphers([email protected]/OutputRecord.java:224) at sun.security.ssl.KeyUpdate$KeyUpdateProducer.produce([email protected]/KeyUpdate.java:321) at sun.security.ssl.KeyUpdate$KeyUpdateKickstartProducer.produce([email protected]/KeyUpdate.java:171) at sun.security.ssl.SSLHandshake.kickstart([email protected]/SSLHandshake.java:538)...

Date and DateTime32 are off one day

14

### Description ``` create database if not exists test; CREATE TABLE test.test_date ( `dt_date32` Date32 NOT NULL, `dt_date` Date NOT NULL ) ENGINE = MergeTree ORDER BY dt_date32; insert into...

Simplify the process of adding more tables to replicate.

5

**How to reproduce :** in `config.yml` ``` database.include.list: "mydb" table.include.list: "mydb.mytable" snapshot.mode: "schema_only" ``` - start the sink-connector (docker-compose up) - check that replication is working fine (no error in...

**How to reproduce :** - replicate a table only in `config.yml` ``` table.include.list: "mydb.mytable" ``` - do not write to the table on the source database side - monitor the...