Paul Zhang
|
8002de4a5b
|
[common] Allow user to pass custom JsonConverter configs in JsonDebeziumDeserializationSchema (#615)
|
3 years ago |
Shengkai
|
fc5538bc3e
|
[common] Fix emitDelay and fetchDelay metrics to be 0L during snapshot phase (#878)
|
3 years ago |
wangxiaojing
|
b21466a848
|
[common] Make Flink CDC Compatible with Flink 1.14
|
3 years ago |
gongzhongqiang
|
5c7e2602be
|
[sqlserver] Add SqlServer cdc connector (#662)
Co-authored-by: Leonard Xu <leonard@apache.org>
|
3 years ago |
Leonard Xu
|
6174c7e690
|
[build] Bump version to 2.2-SNAPSHOT
|
3 years ago |
Jark Wu
|
61ee775b49
|
[tests] Add end-to-end tests for cdc connector uber jars (#594)
|
3 years ago |
|
gongzhongqiang
|
dc5a0c20df
|
[mysql] Reading a null column with default value defined should return null instead of default value (#555)
|
3 years ago |
mincwang
|
5ec35a840f
|
[common] Fix NPE of JsonConverter when job run on cluster(#470)
|
3 years ago |
luoyuxia
|
eeae69cdf9
|
[mysql] support all mysql data types (#438)
This closes #438
|
3 years ago |
Tamas Kiss
|
1fbd429314
|
[oracle] Fixing unit tests, cleaning up after adding oracle cdc.
|
3 years ago |
jpatel
|
3ea40efcc2
|
[oracle] Add oracle cdc connector
This commit does not contain secrets
|
3 years ago |
|
Jark Wu
|
12f27acda2
|
[mysql] Support metadata columns for mysql-cdc connector (#496)
|
3 years ago |
|
luoyuxia
|
64fc3e34b5
|
[common] Support to read tables of inconsistent schema (#494)
|
3 years ago |
|
Shengkai
|
39b326fe26
|
[common] Shade kafka-related dependency (#386)
|
3 years ago |
|
mincwang
|
7f12859304
|
[common] Support json deserialization schema
|
3 years ago |
lsy
|
492fa4f437
|
[common] Remove useless parameter 'converter.schemas.enable'
|
3 years ago |
|
gongzhongqiang
|
08e9c756e1
|
[docs] Update the debezium document link to version 1.5
|
4 years ago |
manmao
|
23bdc7a95b
|
[postgres] Fix Validator didn't implement Serializable
Co-authored-by: mao.man@rootcloud.com <mao.man@rootcloud.com>
|
4 years ago |
Leonard Xu
|
9ee80c5239
|
[build] Bump version to 2.1-SNAPSHOT
|
4 years ago |
|
Shengkai
|
2f644007e2
|
[mysql] Validate MySQL server configuration (version, binlog_format, binlog_row_image) before start job
This closes #211
|
4 years ago |
Leonard Xu
|
8162dc7ae3
|
[build] Rename group.id and packge name from 'com.alibaba.ververica' to 'com.ververica' (#287)
|
4 years ago |
|
Leonard Xu
|
848a6bfefc
|
[debezium] Avoid uncompleted state of schema history when engine stop before checkpoint
* This close (#282)
|
4 years ago |
|
Jark Wu
|
c4a7d6ad56
|
[build] Bump version to 2.0-SNAPSHOT
|
4 years ago |
|
Leonard Xu
|
dd3826be11
|
[mysql] Use SchemaRecord for MySQL cdc source
|
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 |
|
Shengkai
|
679b940341
|
[common] Add support for JDK 9+ (#194)
|
4 years ago |
Ward Harris
|
6aa9f43a4e
|
[debezium] Correct variable name in RowDataDebeziumDeserializeSchema#extractBeforeRow
|
4 years ago |
|
Leonard Xu
|
f37f3998e2
|
[build] Bump version to 1.5-SNAPSHOT
|
4 years ago |
|
Jark Wu
|
d6814f7a27
|
[build] Bump version to 1.4-SNAPSHOT
|
4 years ago |
|
Jark Wu
|
5539094917
|
[debezium] Add source metrics according to FLIP-33
|
4 years ago |
|
Jark Wu
|
ea01014c64
|
[mysql] Add tests for monitoring empty MySQL table
|
4 years ago |
Michael_Xu
|
f99887755a
|
[mysql] Fix NPE when the application started for the first time and captured a empty table
This closes #119
|
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 |
赵万梓
|
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
|
4 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 |