This is an automated email from the ASF dual-hosted git repository.
dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
The following commit(s) were added to refs/heads/master by this push:
new c36298c209 [INLONG-8667][Sort] Fix the class name error in
OracleSnapshotContext (#8668)
c36298c209 is described below
commit c36298c2096df08d4de1d442547373b775bc3e75
Author: emhui <[email protected]>
AuthorDate: Wed Aug 9 11:02:40 2023 +0800
[INLONG-8667][Sort] Fix the class name error in OracleSnapshotContext
(#8668)
---
.../sort/cdc/oracle/source/reader/fetch/OracleScanFetchTask.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git
a/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/oracle-cdc/src/main/java/org/apache/inlong/sort/cdc/oracle/source/reader/fetch/OracleScanFetchTask.java
b/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/oracle-cdc/src/main/java/org/apache/inlong/sort/cdc/oracle/source/reader/fetch/OracleScanFetchTask.java
index c6cf1c6095..eb7111a8c7 100644
---
a/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/oracle-cdc/src/main/java/org/apache/inlong/sort/cdc/oracle/source/reader/fetch/OracleScanFetchTask.java
+++
b/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/oracle-cdc/src/main/java/org/apache/inlong/sort/cdc/oracle/source/reader/fetch/OracleScanFetchTask.java
@@ -298,14 +298,14 @@ public class OracleScanFetchTask implements
FetchTask<SourceSplitBase> {
@Override
protected SnapshotContext prepare(ChangeEventSourceContext
changeEventSourceContext)
throws Exception {
- return new MySqlSnapshotContext();
+ return new OracleSnapshotContext();
}
- private static class MySqlSnapshotContext
+ private static class OracleSnapshotContext
extends
RelationalSnapshotChangeEventSource.RelationalSnapshotContext {
- public MySqlSnapshotContext() throws SQLException {
+ public OracleSnapshotContext() throws SQLException {
super("");
}
}