-
Notifications
You must be signed in to change notification settings - Fork 2k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[cdc-connector][db2] Db2 support incremental source #2870
Conversation
@leonardBang @GOODBOY008 PTAL |
@leonardBang test_1_ci_build core fail. because this PR #2845 cause error. I rollback this change. |
91b96f5
to
4eeb46e
Compare
random UT fail that is not relate with the db2 |
4eeb46e
to
e414129
Compare
e414129
to
44f8cc9
Compare
...k-connector-db2-cdc/src/main/java/com/ververica/cdc/connectors/db2/table/StartupOptions.java
Outdated
Show resolved
Hide resolved
44f8cc9
to
357a571
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks for this great contribution, left some comments.
...onnector-db2-cdc/src/main/java/com/ververica/cdc/connectors/db2/source/Db2SourceBuilder.java
Outdated
Show resolved
Hide resolved
...-db2-cdc/src/main/java/com/ververica/cdc/connectors/db2/source/dialect/Db2ChunkSplitter.java
Outdated
Show resolved
Hide resolved
...nector-db2-cdc/src/main/java/com/ververica/cdc/connectors/db2/source/utils/Db2TypeUtils.java
Outdated
Show resolved
Hide resolved
...-connector-db2-cdc/src/main/java/com/ververica/cdc/connectors/db2/source/utils/Db2Utils.java
Outdated
Show resolved
Hide resolved
...-connector-db2-cdc/src/main/java/com/ververica/cdc/connectors/db2/source/utils/Db2Utils.java
Outdated
Show resolved
Hide resolved
357a571
to
c728723
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Overall look good to me, left some comments.
...nnector-db2-cdc/src/test/java/com/ververica/cdc/connectors/db2/table/Db2ConnectorITCase.java
Outdated
Show resolved
Hide resolved
...or-db2-cdc/src/main/java/com/ververica/cdc/connectors/db2/source/fetch/Db2ScanFetchTask.java
Outdated
Show resolved
Hide resolved
...or-db2-cdc/src/main/java/com/ververica/cdc/connectors/db2/source/fetch/Db2ScanFetchTask.java
Outdated
Show resolved
Hide resolved
Hi @gong There is a failure in https://dev.azure.com/ververica/flink-cdc-connectors/_build/results?buildId=4654&view=logs&j=450e5386-ec4e-5c3c-8d86-ea427d28cb6f&t=b72b380c-c1b9-55cc-a168-123a50838bbf, could you please take a look? |
@lvyanquan ok |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM.
There is a mix of binlog
redolog
and wal
in the code, it is best to unify them.
@lvyanquan ok |
I will rebase code after #2978 is merged. |
5d1cdd4
to
f73a545
Compare
f73a545
to
617be76
Compare
d28278c
to
a489e46
Compare
@lvyanquan CI error is not related with the PR. UT can pass in local. |
a489e46
to
db04a47
Compare
fba9516
to
93085e2
Compare
93085e2
to
5ed9cf3
Compare
Thanks @gong for the great work, I'd like to have a final review base on @lvyanquan 's review work. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks @gong for the contribution and @lvyanquan for the review, generally looks good to me, I append a minor commit to improve the code style.
80add56
to
6abf4d4
Compare
6abf4d4
to
1c8209c
Compare
1c8209c
to
2cfb89d
Compare
CI passed, merging... |
Prepare a Pull Request
Motivation
Db2 support incremental source
Modifications