-
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
[FLINK-34944] Use Incremental Source Framework in Flink CDC OceanBase Source Connector #3211
base: master
Are you sure you want to change the base?
Conversation
ac358c4
to
d539899
Compare
d539899
to
7cc477f
Compare
docs/content.zh/docs/connectors/legacy-flink-cdc-sources/oceanbase-cdc.md
Outdated
Show resolved
Hide resolved
7cc477f
to
19d560d
Compare
hello,When can this feature be merged into version 3.2? |
I will add test cases for this PR in the next two days, and after that we can ask the committers to review it. |
19d560d
to
469603d
Compare
This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. |
This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. |
@whhe RichSourceFunction is Deprecated interface,We can implements use Source interface? |
JdbcIncrementalSource implements new Source interface :) |
Please rebase the master branch and revert changes in #3831 . |
cbcb821
to
93053b5
Compare
Signed-off-by: He Wang <wanghechn@qq.com>
93053b5
to
bbd03ee
Compare
This pr is based on #3124. Docs and test cases are WIP and will be updated later.