fix ci not pass

apache · Aug 12, 2023 · bbd17f6 · bbd17f6
1 parent d9d0f67
commit bbd17f6
Show file tree

Hide file tree

Showing 6 changed files with 14 additions and 8 deletions.
diff --git a/...or-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/JdbcSourceConnector.java b/...or-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/JdbcSourceConnector.java
@@ -32,7 +32,8 @@
 import org.apache.eventmesh.openconnect.api.config.Config;
 import org.apache.eventmesh.openconnect.api.config.SourceConfig;
 import org.apache.eventmesh.openconnect.api.connector.SourceConnector;
-import org.apache.eventmesh.openconnect.api.data.ConnectRecord;
+import org.apache.eventmesh.openconnect.offsetmgmt.api.data.ConnectRecord;
+
 
 import org.apache.commons.collections4.CollectionUtils;
 

diff --git a/...jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/TaskManagerCoordinator.java b/...jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/TaskManagerCoordinator.java
@@ -18,7 +18,9 @@
 
 package org.apache.eventmesh.connector.jdbc.source;
 
-import org.apache.eventmesh.openconnect.api.data.ConnectRecord;
+
+
+import org.apache.eventmesh.openconnect.offsetmgmt.api.data.ConnectRecord;
 
 import org.apache.commons.collections4.CollectionUtils;
 

diff --git a/...or-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/TaskManagerListener.java b/...or-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/TaskManagerListener.java
@@ -17,7 +17,7 @@
 
 package org.apache.eventmesh.connector.jdbc.source;
 
-import org.apache.eventmesh.openconnect.api.data.ConnectRecord;
+import org.apache.eventmesh.openconnect.offsetmgmt.api.data.ConnectRecord;
 
 import java.util.List;
 

diff --git a/.../src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/cdc/CdcTaskManager.java b/.../src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/cdc/CdcTaskManager.java
@@ -28,9 +28,10 @@
 import org.apache.eventmesh.connector.jdbc.table.catalog.TableId;
 import org.apache.eventmesh.connector.jdbc.table.type.EventMeshRow;
 import org.apache.eventmesh.connector.jdbc.table.type.RowHandleMode;
-import org.apache.eventmesh.openconnect.api.data.ConnectRecord;
-import org.apache.eventmesh.openconnect.api.data.RecordOffset;
-import org.apache.eventmesh.openconnect.api.data.RecordPartition;
+import org.apache.eventmesh.openconnect.offsetmgmt.api.data.ConnectRecord;
+import org.apache.eventmesh.openconnect.offsetmgmt.api.data.RecordOffset;
+import org.apache.eventmesh.openconnect.offsetmgmt.api.data.RecordPartition;
+
 
 import org.apache.commons.collections4.CollectionUtils;
 

diff --git a/...java/org/apache/eventmesh/connector/jdbc/source/dialect/snapshot/SnapshotTaskManager.java b/...java/org/apache/eventmesh/connector/jdbc/source/dialect/snapshot/SnapshotTaskManager.java
@@ -27,8 +27,9 @@
 import org.apache.eventmesh.connector.jdbc.source.dialect.cdc.CdcTaskSelectStrategy;
 import org.apache.eventmesh.connector.jdbc.source.dialect.cdc.RandomCdcTaskSelectStrategy;
 import org.apache.eventmesh.connector.jdbc.table.catalog.TableId;
-import org.apache.eventmesh.openconnect.api.data.ConnectRecord;
-import org.apache.eventmesh.openconnect.api.data.RecordPartition;
+import org.apache.eventmesh.openconnect.offsetmgmt.api.data.ConnectRecord;
+import org.apache.eventmesh.openconnect.offsetmgmt.api.data.RecordPartition;
+
 
 import org.apache.commons.collections4.CollectionUtils;
 

diff --git a/eventmesh-spi/src/main/java/org/apache/eventmesh/spi/EventMeshExtensionType.java b/eventmesh-spi/src/main/java/org/apache/eventmesh/spi/EventMeshExtensionType.java
@@ -30,6 +30,7 @@ public enum EventMeshExtensionType {
     METRICS("metrics"),
     TRACE("trace"),
     JDBC_CDC_ENGINE("jdbc_cdc_engine"),
+    JDBC_SNAPSHOT_ENGINE("jdbc_snapshot_engine"),
     JDBC_DATABASE_DIALECT("jdbc_database_dialect"),
     OFFSETMGMT("offsetMgmt"),
     ;