-
Notifications
You must be signed in to change notification settings - Fork 534
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
[INLONG-10703][Manager] Manager Add Oceanbase Support #10701
Conversation
.../main/java/org/apache/inlong/manager/service/resource/sink/oceanbase/OceanBaseJdbcUtils.java
Show resolved
Hide resolved
...ager-pojo/src/main/java/org/apache/inlong/manager/pojo/schedule/OfflineJobSubmitRequest.java
Outdated
Show resolved
Hide resolved
|
...rc/main/java/org/apache/inlong/manager/service/source/oceanbase/OceanBaseSourceOperator.java
Outdated
Show resolved
Hide resolved
...rc/main/java/org/apache/inlong/manager/service/source/oceanbase/OceanBaseSourceOperator.java
Outdated
Show resolved
Hide resolved
@xxsc0529 please fix the failed workflow and comments, thanks. |
This codeQL doesn't work.,The same logic as mysql here.,I can't detect a lot of the original code here.,Do you have to solve this problem?,If you look at this diagram, the original code containing the DriverManager.getConnection logic did not pass codeQl |
...ojo/src/main/java/org/apache/inlong/manager/pojo/source/oceanbase/OceanBaseBinlogSource.java
Outdated
Show resolved
Hide resolved
.../main/java/org/apache/inlong/manager/pojo/source/oceanbase/OceanBaseBinlogSourceRequest.java
Outdated
Show resolved
Hide resolved
@xxsc0529 you could ignore the CodeQL fails, but it's better to click |
Resolved |
Fixes #10703
Motivation
Added support for Oceanbase data sources to adapt to the Oceanbase ecosystem. close #10703
Modifications
It mainly adds oceanbase data source support and uses the oceanbase-client driver to connect.
It mainly adds oceanbase data source support and uses the oceanbase-client driver to connect. And write oceanbase's ExtractNode logic and LoadNode logic. The specific implementation logic is the same as mysql.Added support for oceanbase on the front-end page. Since the jdbc-inlong processing logic in the flink15 connection lacks the jdbc dialect, an error is reported. This is modified here.
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)
Here's how the page test works
This change added tests and can be verified as follows:
Please use the following test classes for testing org.apache.inlong.sort.parser.MySqlExtractNodeToOceanBaseLoadNodeTest
(example:)
Documentation