This is an automated email from the ASF dual-hosted git repository.
wanghailin 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 52d1020eb7 [Fix] Fix ConnectorSpecificationCheckTest failed (#6828)
52d1020eb7 is described below
commit 52d1020eb7dcde618430a20c5922bf4ee93eac97
Author: Jia Fan <[email protected]>
AuthorDate: Fri May 10 15:24:57 2024 +0800
[Fix] Fix ConnectorSpecificationCheckTest failed (#6828)
---
.../seatunnel/cdc/oracle/source/OracleIncrementalSource.java | 5 -----
1 file changed, 5 deletions(-)
diff --git
a/seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/source/OracleIncrementalSource.java
b/seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/source/OracleIncrementalSource.java
index 9bcd8f8845..53a82b2e2f 100644
---
a/seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/source/OracleIncrementalSource.java
+++
b/seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/source/OracleIncrementalSource.java
@@ -19,7 +19,6 @@ package
org.apache.seatunnel.connectors.seatunnel.cdc.oracle.source;
import org.apache.seatunnel.api.configuration.Option;
import org.apache.seatunnel.api.configuration.ReadonlyConfig;
-import org.apache.seatunnel.api.source.SeaTunnelSource;
import org.apache.seatunnel.api.source.SupportParallelism;
import org.apache.seatunnel.api.table.catalog.CatalogTable;
import org.apache.seatunnel.api.table.type.SeaTunnelDataType;
@@ -43,12 +42,10 @@ import
org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.JdbcCatalogOptions
import org.apache.kafka.connect.data.Struct;
-import com.google.auto.service.AutoService;
import io.debezium.jdbc.JdbcConnection;
import io.debezium.relational.TableId;
import io.debezium.relational.history.ConnectTableChangeSerializer;
import io.debezium.relational.history.TableChanges;
-import lombok.NoArgsConstructor;
import java.time.ZoneId;
import java.util.List;
@@ -56,8 +53,6 @@ import java.util.Map;
import java.util.function.Function;
import java.util.stream.Collectors;
-@NoArgsConstructor
-@AutoService(SeaTunnelSource.class)
public class OracleIncrementalSource<T> extends IncrementalSource<T,
JdbcSourceConfig>
implements SupportParallelism {