赵万梓
|
c34d9776e7
|
[postgres] Flush LSN offset to PG even if no updates to the monitored tables to avoid infinite WAL segments (#111)
This closes #111
|
4 years ago |
Jark Wu
|
c1c96a6ac7
|
[build] Bump version to 1.3-SNAPSHOT
|
4 years ago |
Jark Wu
|
4127661092
|
[postgres] Flush LSN offset to PG after checkpoint complete to avoid infinite WAL segments
|
4 years ago |
Jark Wu
|
1ee4264e9f
|
[debezium] Remove logging security properties
|
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 |
Jark Wu
|
799b5d36af
|
[debezium] Rename DebeziumState to DebeziumOffset
|
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
|
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 |
Jark Wu
|
a47cb90d83
|
[hotfix] Fix the missing license header
|
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
|
39c5c9507b
|
[build] Bump Flink version to 1.11.1
|
5 years ago |
Jark Wu
|
5120a5b35b
|
[build] Update version to 1.0.0-SNAPSHOT
|
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
|
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 |