-
Notifications
You must be signed in to change notification settings - Fork 169
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-34572] Support OceanBase Jdbc Catalog #109
Conversation
Would you please take a look on this? @leonardBang |
@MartijnVisser PTAL |
6b8c734
to
12a77ba
Compare
@eskabetxe PTAL |
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.
I left some minor comments
.../main/java/org/apache/flink/connector/jdbc/databases/oceanbase/catalog/OceanBaseCatalog.java
Outdated
Show resolved
Hide resolved
...rg/apache/flink/connector/jdbc/databases/oceanbase/catalog/OceanBaseOracleCatalogITCase.java
Outdated
Show resolved
Hide resolved
.../main/java/org/apache/flink/connector/jdbc/databases/oceanbase/catalog/OceanBaseCatalog.java
Outdated
Show resolved
Hide resolved
Hi @eskabetxe, I updated these files, please take a look again. |
@eskabetxe PTAL |
Anyone available? @eskabetxe @GOODBOY008 @leonardBang |
132291c
to
b8dca26
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.
Hi, @whhe Thx for the contribution.
Would you mind fixing the failed CI action before the next review ?
3cd69a4
to
3c15974
Compare
Hi @RocMarshal, the CI failure is fixed now. PTAL |
e9c5fec
to
ead7ff0
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 @whhe for the contribution.
Left a few of comments. PTAL ~
Thanks for your review, the documentations have been updated as suggested. PTAL. |
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 @whhe for the update.
Left a few of comments.
...k-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/JdbcCatalogUtils.java
Outdated
Show resolved
Hide resolved
...in/java/org/apache/flink/connector/jdbc/databases/oceanbase/catalog/OceanBaseTypeMapper.java
Outdated
Show resolved
Hide resolved
.../flink/connector/jdbc/databases/oceanbase/table/OceanBaseOracleDynamicTableSourceITCase.java
Outdated
Show resolved
Hide resolved
@RocMarshal Updated. PTAL |
@whhe nice 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 @whhe for the hard work!
LGTM +1,
now ping @snuyanzin @eskabetxe
f2a7fb8
to
3a7aec6
Compare
@leonardBang @MartijnVisser @GOODBOY008 Can someone help with the review? |
215698e
to
6a4b58a
Compare
@eskabetxe PTAL |
...nbase/src/main/java/org/apache/flink/connector/jdbc/oceanbase/database/OceanBaseFactory.java
Outdated
Show resolved
Hide resolved
...c/main/java/org/apache/flink/connector/jdbc/oceanbase/database/catalog/OceanBaseCatalog.java
Outdated
Show resolved
Hide resolved
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, @1996fanrui can you check
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 @whhe for the contribution, and thanks @RocMarshal & @eskabetxe for the review!
Merging
No description provided.