-
Notifications
You must be signed in to change notification settings - Fork 1.9k
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
[Feature][Connector-V2]Support tidb cdc connector source #7477
Conversation
fb39521
to
5574bdd
Compare
.idea/vcs.xml
Outdated
@@ -1,24 +1,5 @@ | |||
<?xml version="1.0" encoding="UTF-8"?> | |||
<!-- |
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.
why update this file
@@ -0,0 +1,129 @@ | |||
# PostgreSQL CDC |
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.
Please add zh docs
@@ -140,7 +142,9 @@ public Column convert(BasicTypeDefine typeDefine) { | |||
case MYSQL_NULL: | |||
builder.dataType(BasicType.VOID_TYPE); | |||
break; | |||
|
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.
revert
value = {}, | ||
type = {EngineType.SPARK}, | ||
disabledReason = "Currently SPARK do not support cdc") | ||
public class TiDBCDCIT extends TiDBTestBase implements TestResource { |
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.
8267c66
to
4bc7d20
Compare
|
||
## 主要功能 | ||
|
||
- [x] [批处理](../../concept/connector-v2-features.md) |
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.
support batch mode?
cc @dailai |
90ba526
to
bbae550
Compare
Please resolve the confilict and retrigger the ci. |
bbae550
to
1f72f52
Compare
Please fix the ci. |
3e63cac
to
090fcdf
Compare
value = {}, | ||
type = {EngineType.SPARK}, | ||
disabledReason = "Currently SPARK do not support cdc") | ||
public class TiDBCDCIT extends TiDBTestBase implements TestResource { |
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 @sunxiaojian. Please add the e2e case that restore from savepoint.
b562f81
to
c4d1fde
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.
LGTM
c4d1fde
to
7605b2a
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.
LGTM
Purpose of this pull request
closed #7199
Does this PR introduce any user-facing change?
How was this patch tested?
Check list
New License Guide
release-note
.