github-forks
/
flink-cdc-connectors
mirror of https://github.com/ververica/flink-cdc-connectors.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
1,010 Commits
15 Branches
34 Tags
63 MiB
Commit Graph

1010 Commits (11deb62637fe0ee7ee588ecbb3fb395d7e2bb3fc)
 

Author SHA1 Message Date
gongzhongqiang cdfc86f670
[build] Polish CI scripts and remove useless code () 
This closes .
Hang Ruan 14213087c1
[mysql] fix parsing ddl error when use string default values for numeric types () 
This closes .
Leonard Xu a264188c67
[mysql] Enumerate captured tables lazily () 
This closes .
Leonard Xu 71c16d5d52
[mysql] Reduce the memory usage of JM by sharing table schemas between splits () 
This closes .
empcl cf8a2f4b07
[hotfix][docs] Fix comment typo in MysqlSnapshotSplit () 
Co-authored-by: chenlei677 <chenlei677@jd.com>
Leonard Xu 72c806cb9d
[mysql] Let all records of one snapshot split don't cross checkpoints () 
This closes .
Sergey Nuyanzin 9f97e06f32
[tests] Remove usage of deprecated EnvironmentSettings.Builder#useBlinkPlanner () 
This closes .
Leonard Xu 238305b2d9
[cdc-base][mysql] Fix split key comparison when may contain different types () 
This closes .
leixin dbd184ec36
[docs][mysql] Update the description of mysql server-time-zone option () 
Co-authored-by: leixin1 <leixin1@jd.com>
Kyle Dong b3ebf3da69
[mysql] Use local timezone as the default value of 'server-time-zone' option () 
This closes  .
JiaJia 11c1d84dfa
[docs][postgres] Add two frequently debezium options in Postgres connector document () 
This closes .
vanliu ed980ef499
[mongodb] Allow mongo ARRAY to be converted to string type in Flink ()
skylines 1b17a751cc
[hotfix][docs] Fix the page links in MySQL Chinese document () 
This closes .
He Wang d0d40d05c7
[oceanbase][test] Use memory mode of obcdc and double startup timeout duration () 
This closes .
Leonard Xu cfbd00fa34 [mysql][polardbx] Stop container timely in tests ()
Hang Ruan 7c9b30276d [mysql][ploardbx] Support all charsets in column level () 
This closes .
Jiabao Sun 3d255fca83
[mongodb] Expose updateLookup option for stream source. ()
He Wang e83810ff67
[oceanbase] Use utc offset as 'server-time-zone' option's default value ()
lidoudou1993 6a2f470ae3
[mysql][minor] Skip capture newly added tables according snapshotassigner's status () 
Co-authored-by: lidoudou3 <lidoudou1@jd.com>
Leonard Xu 638474d6c7 [polardbx][test] Bump the polardb-x image version from 2.0.1 to 2.10 ()
He Wang 299cfc8232 [build][test] Specify surefire provider to surefire-junit47 () 
This closes ,
legendtkl 617a29be2c
[hotfix][docs] Fix typo in bug report doc () 
Co-authored-by: taokelu <taokelu@bytedance.com>
Leonard Xu dda1c3e6a1 [minor][oracle] Rename JdbcConfigurationUtil to OracleJdbcUrlUtils
dujie 0292a39a3c [oracle] Support custom JDBC URL for Oracle () 
This closes .
empcl 45fd69692f
[docs] Correct the data type of 'server-id' option to String () 
Co-authored-by: chenlei677 <chenlei677@jd.com>
Hang Ruan 6a56985fa8
[hotfix][test] Fix MySqlSourceITCase failure due to StreamExecutionEnvironment#getConfiguration returned unmodifiable object ()
Hang Ruan 2bb5b6f625
[test] Fix tests missed 'update_before' records if the primary keys of source and sink are different ()
legendtkl 8849d14aeb
[hotfix][oracle] Fix the shell script interpreter assignment should be at first line () 
Co-authored-by: taokelu <taokelu@bytedance.com>
gongzhongqiang 6af93959c2
[hotfix][tidb-cdc] TiDB CDC dealUnsignedColumnValue throw NullPointerException. ()
Hang Ruan 9e6549c67e
[polardbx][test] Rename PolardbxSourceTCase to PolardbxSourceITCase ()
Hang Ruan a5dd0c0a14
[mysql] Enable pass custom jdbc properties for debezium mysql connection () 
This closes
Matrix42 c96926b6ec
[mysql] Release the debezium reader thread resources after reading finished () 
This closes .
He Wang 2de4903261
[oceanbase] Introduce 'table-list' option to support capture list of tables () 
This closes .
ehui 043841624d
[cdc-base] Flink CDC base registers the identical history engine on multiple tasks () 
This closes
Leonard Xu 70ebfefa9c [hotfix][mysql] Fix compile error due to merge conflict
Hang Ruan 96c84d9c65
[mysql] Generates multiple chunks when approximate row count is bigger than chunk size () 
This closes .
ehui 0a097a9e53
[cdc-base] Fix NPE during snpashot scan phase () 
This closes .
Leonard Xu 52368e5b87 [docs] Improve MySQL ZH document and update the outdated links () 
This closes .
rookiegao 5eabe38aef [docs] Translate mysql cdc doc to Chinese () 
This closes .
Hang Ruan 0d1ce7a702
[mysql] Introduce 'scan.incremental.snapshot.chunk.key-column' option to support splitting table by custom column () 
This closes .
lzshlzsh 74f0a65355
[mysql] Optimize pure binlog phase check logic to improve performance () 
Co-authored-by: sammieliu <sammieliu@tencent.com>
zhmin 2c3962bd03
fix typo of SourceReaderMetrics's name () 
Co-authored-by: zhmin <minzhe@loongteam.com>
Leonard Xu 7afa2e1675 [oracle] Fix mining session stopped due to 'No more data to read from socket'
Leonard Xu 1ab2c6de71 [common] Ignore retriableException to make the debezium engine retry works 
[test][oracle] Fix unstable tests OracleE2eITCase due to reuse container
Paul Lin 4a6a89903c
[tidb] Fix NPE when the specified table does not exist () 
This closes .
gongzhongqiang 657f4364d5 [docs] Add step up SQLServer Database cdc document in sqlserver-cdc.md.
Jiabao Sun 02eca305d2
[mongodb] Expose batch.size config option for table source. () 
* [mongodb] Expose batch.size config option for table source.
Jiabao Sun 3ce8f824d2
[mongodb] Example tests for MongoDBSource ()
Leonard Xu a10ae4624e
[build] Use correct year and copyright owner in license files () 
This closes .
vanliu 42631af6f5
[mongodb] Allow document field defined as string type in flink sql ()