Leonard Xu
|
b6ee80862e
|
[doc] Support markdown tables in document website by recommonmark
|
4 years ago |
Leonard Xu
|
698c0ccad0
|
[doc] Fix document search fail due to sphinx-doc/sphinx/issues/8419
|
4 years ago |
Leonard Xu
|
85a0636045
|
[doc] Support versioned documents with RTD(ReadTheDocs)
|
4 years ago |
Leonard Xu
|
7d7ca57e24
|
[doc] Use sphinx-rtd-theme to manage project documents
|
4 years ago |
Leonard Xu
|
d7fd46d0be
|
[doc] Set build_docs.yml for document building
|
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
|
5180bc984f
|
[mysql] Refactor split assigner and simplify chunk splitting (#283)
|
4 years ago |
Leonard Xu
|
2edf6d3778
|
[mysql] Enable single server id for MySqlParallelSource
|
4 years ago |
Leonard Xu
|
e894b0a69e
|
[mysql] Keep the global order of between snapshot records and binlog records
|
4 years ago |
Leonard Xu
|
8638720d71
|
[mysql] Support latest-offset mode for MySqlParallelSource
|
4 years ago |
Leonard Xu
|
75c01c530e
|
[mysql] Simplify the options for Mysql Source
|
4 years ago |
Jark Wu
|
ff6b638262
|
[mysql] Improve split state and enumerator state structure
|
4 years ago |
Jark Wu
|
7d369548b0
|
[mysql] Move MySqlSplitReader from 'split' to 'reader' package
|
4 years ago |
Jark Wu
|
a42f6ae61c
|
[mysql] Simplify EmbeddedFlinkDatabaseHistory to not record schema changes
|
4 years ago |
Leonard Xu
|
ae54f0b11a
|
[mysql] Throw underlying debezium reader exception
|
4 years ago |
Leonard Xu
|
35c636224d
|
[mysql] Make every subtask used different database history
|
4 years ago |
Leonard Xu
|
a0e5e7a65b
|
[mysql] Optimize the data structure of split and splitState
This closes #268
|
4 years ago |
Leonard Xu
|
5542233278
|
[mysql] Add JM/TM failover tests to check checkpoint works fine
|
4 years ago |
Leonard Xu
|
d5e3dc709a
|
[build] Bump flink version to 1.13.1
|
4 years ago |
Jark Wu
|
c4a7d6ad56
|
[build] Bump version to 2.0-SNAPSHOT
|
4 years ago |
Jark Wu
|
ce2ee32521
|
[mysql][test] Rename "custom.sql" to "customer.sql"
|
4 years ago |
Jark Wu
|
e9e78f10d6
|
[mysql] Refactor class names to use "MySql" prefix instead of "MySQL"
|
4 years ago |
Jark Wu
|
6827aad0a4
|
[mysql] Use LOG instead of LOGGER as Logger variable name
|
4 years ago |
Jark Wu
|
6e5e14dc34
|
[mysql] Rename BinlogPosition to BinlogOffset
|
4 years ago |
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 |
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 |
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
|
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 |
Jark Wu
|
882c9204a1
|
[build] Add Spotless plugin with Google AOSP style
|
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
|
0ce58b4ff5
|
[postgres] Support 'slot.name' option for postgres-cdc connector
|
4 years ago |