Leonard Xu
|
5786506394
|
[mysql] Support binlog reader merge optimization
This close #256
|
4 years ago |
|
Leonard Xu
|
6231e990c0
|
[mysql] Support numeric type optimization for split boundary calculation
This close (#248)
|
4 years ago |
Leonard Xu
|
c6ca6c1874
|
[mysql] Support new Source in SQL
|
4 years ago |
|
Leonard Xu
|
dd3826be11
|
[mysql] Use SchemaRecord for MySQL cdc source
|
4 years ago |
|
Leonard Xu
|
1a81915cd1
|
[mysql] Support table with combined primary key
|
4 years ago |
|
Leonard Xu
|
088dc5c049
|
[mysql] Add more tests for assigner and new Source
|
4 years ago |
|
Leonard Xu
|
a781a88817
|
[mysql] First draft for MySQL-CDC 2.0
|
4 years ago |
Jiabao Sun
|
ff9bf31b19
|
[common] Fix ClassCastException in type conversion
[common] Fix ClassCastException in type conversion, this close(#226)
|
4 years ago |
Shengkai
|
fcea3d14f7
|
[common] Fix schema history run out of memory
Fix schema history run out of memory, this close (#207)
Co-authored-by: Leonard Xu <xbjtdcq@gmail.com>
|
4 years ago |
|
Leonard Xu
|
5195647576
|
[debezium] Bump debezium version to 1.5.2.Final (#205)
* [debezium] Upgrade the Debezium to 1.5.2.Final
Co-authored-by: Shengkai <1059623455@qq.com>
|
4 years ago |
|
Leonard Xu
|
f37f3998e2
|
[build] Bump version to 1.5-SNAPSHOT
|
4 years ago |
|
Leonard Xu
|
1436410adf
|
[debezium] Bump Flink version to 1.13.0 (#176)
|
4 years ago |
Jark Wu
|
d6814f7a27
|
[build] Bump version to 1.4-SNAPSHOT
|
4 years ago |
|
Jark Wu
|
ea01014c64
|
[mysql] Add tests for monitoring empty MySQL table
|
4 years ago |
|
Jark Wu
|
116cea690d
|
[mysql] Minor code improvement
|
4 years ago |
|
Jark Wu
|
8925d943bf
|
[build] Format code with Spotless/google-java-format
|
4 years ago |
|
Jark Wu
|
c1c96a6ac7
|
[build] Bump version to 1.3-SNAPSHOT
|
4 years ago |
|
Jark Wu
|
1ee4264e9f
|
[debezium] Remove logging security properties
|
4 years ago |
|
Jark Wu
|
5264e80a7b
|
[mysql] Support read binlog from specific timestamp
|
4 years ago |
|
Jark Wu
|
5fcfe8ca05
|
[mysql] Support "initial", "earliest-offset", "latest-offset" startup mode options
|
4 years ago |
|
Jark Wu
|
c47526737e
|
[mysql] Improve implementation of specifying binlog position and add tests
|
4 years ago |
shizhengchao
|
befb4adbd9
|
[mysql] Support read from specific MySQL Binlog position
|
4 years ago |
|
jiabao.sun
|
2dfb59f3c7
|
[build] Bump up Flink version to 1.12.1 (#95)
|
4 years ago |
|
Jark Wu
|
05a28a4428
|
[build] Set up CI with Azure Pipelines (#108)
This requires to upgrade testcontainers to 1.15.1 to fix can't pull images problem
|
4 years ago |
陈小东
|
6c4f1f8528
|
[fix bug] offset state missing if no binlog fetched tile checkpoint after restore.
|
4 years ago |
Zhenghua Gao
|
e2d4ff735c
|
[ISSUE-69] DebeziumSourceFunction only stores monitored table DDLs which cause error in some situation
This closes #70
|
4 years ago |
|
Jark Wu
|
0c8fcbbeca
|
[build] Bump version to 1.2-SNAPSHOT
|
5 years ago |
|
Jark Wu
|
3dc2f0d5cf
|
[mysql][postgres] Use underscore for the database.server.name to avoid Kafka warning log
|
5 years ago |
|
Jark Wu
|
5e9aa0b733
|
[mysql] Ignore exceptions when encountered unparseable DDL
|
5 years ago |
|
Jark Wu
|
f6b7b35a35
|
Support to parse MySQL TIMESTAMP type and support "server-time-zone" option
This fixes #17 and #16
|
5 years ago |
|
Jark Wu
|
bfa1fc3f91
|
[build] Bump project version to 1.1.0-SNAPSHOT
|
5 years ago |
qinshiwei
|
c89b46f14a
|
Support "debezium.*" option to pass through the Debezium's properties
This closes #15
|
5 years ago |
|
Jark Wu
|
97b95eda77
|
Move test utils to a separate module
|
5 years ago |
|
Jark Wu
|
5120a5b35b
|
[build] Update version to 1.0.0-SNAPSHOT
|
5 years ago |
|
Jark Wu
|
ad6eeb0fa6
|
[mysql][postgres] Rename MySqlBinlogSource and PostgreSqlChangelogSource to MySQLSource and PostgreSQLSource
|
5 years ago |
|
Jark Wu
|
94e7703f96
|
[postgres] Add PostgreSQL CDC source connector
|
5 years ago |
|
Jark Wu
|
ab3a2ca1a6
|
[test] Move AssertUtils to flink-connector-debezium
|
5 years ago |
|
Jark Wu
|
ffae96de9d
|
Add README and LICENSE
|
5 years ago |
|
Jark Wu
|
524af1c78d
|
[build] Fix shading problems
|
5 years ago |
|
Jark Wu
|
6ed359c694
|
[build] Add flink-sql-connector-mysql-cdc to shade dependencies
|
5 years ago |
|
Jark Wu
|
a0b21b6092
|
[build] Rename modules to 'flink-connector-debezium' and 'flink-connector-mysql-cdc'
|
5 years ago |