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("");
             }
         }

Reply via email to