-
Notifications
You must be signed in to change notification settings - Fork 334
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
[BitSail][MultiTableSInk]Bitsail enabled write multi sink in single task. #472
base: master
Are you sure you want to change the base?
Conversation
@@ -33,6 +33,27 @@ | |||
</properties> | |||
|
|||
<dependencies> | |||
<dependency> | |||
<groupId>io.debezium</groupId> |
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.
can we not include debezium in the cdc base module?
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 not, i think all sub module all need this module?
bitsail-connectors/bitsail-connectors-legacy/bitsail-connector-hive/pom.xml
Show resolved
Hide resolved
@@ -59,6 +59,9 @@ engine.type.to.bitsail.type.converter: | |||
- source.type: date | |||
target.type: date.date | |||
|
|||
- source.type: bit |
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.
does doris has bit
datatype? I didn't see this type when I look at doris documentation.
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.
There have some context, now we need get doris columns by jdbc, and we will get mysql data type.
|
||
<dependencyManagement> |
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.
some cdc connector may not use debezium in the future, let's keep this in the submodule.
private static final int CONTAINS_SCHEMA_TABLE_ID_LENGTH = 3; | ||
|
||
private final String database; | ||
private final String schema; |
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.
can we add UT for this class, curious about how's the format of each obj.
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.
Sure, i will do it.
Prepare a Pull Request
Title: [BitSail-XYZ][XxxType] Title of the pull request
Fixes: #XYZ
Motivation
Describe what this PR does and what problems you're trying to solve.
Modifications
Describe the modifications you've done.
Verifying this change
Please pick either of the following options.
This change is a trivial rework/code cleanup without any test coverage.
This change is already covered by existing tests, such as:
(please describe tests, example:)
This change added tests and can be verified as follows:
(example:)
Documentation