(seatunnel) branch dev updated: [Hotfix][Oracle-CDC] Fix state recovery error when switching a single table to multiple tables (#6211)

[fanjia]

This is an automated email from the ASF dual-hosted git repository.

fanjia pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new 74cfe1995f [Hotfix][Oracle-CDC] Fix state recovery error when 
switching a single table to multiple tables (#6211)
74cfe1995f is described below

commit 74cfe1995f1a1d6397b903a6d046b1a16ece5a19
Author: hailin0 <wanghai...@apache.org>
AuthorDate: Tue Jan 16 08:56:28 2024 +0800

    [Hotfix][Oracle-CDC] Fix state recovery error when switching a single table 
to multiple tables (#6211)
---
 .../seatunnel/cdc/oracle/source/OracleIncrementalSourceFactory.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/source/OracleIncrementalSourceFactory.java
 
b/seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/source/OracleIncrementalSourceFactory.java
index 57ca695b6d..f8f4fb3228 100644
--- 
a/seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/source/OracleIncrementalSourceFactory.java
+++ 
b/seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/source/OracleIncrementalSourceFactory.java
@@ -103,7 +103,7 @@ public class OracleIncrementalSourceFactory implements 
TableSourceFactory {
                     CatalogTableUtil.getCatalogTables(
                             context.getOptions(), context.getClassLoader());
             SeaTunnelDataType<SeaTunnelRow> dataType =
-                    CatalogTableUtil.convertToDataType(catalogTables);
+                    CatalogTableUtil.convertToMultipleRowType(catalogTables);
             return new OracleIncrementalSource(context.getOptions(), dataType, 
catalogTables);
         };
     }