remove cdc depend and case, some example, and change identifier

JNSimba · Sep 13, 2024 · af6144b · af6144b
1 parent 62360c7
commit af6144b
Show file tree

Hide file tree

Showing 63 changed files with 1 addition and 8,437 deletions.
diff --git a/flink-doris-connector/pom.xml b/flink-doris-connector/pom.xml
@@ -277,94 +277,12 @@ under the License.
             <version>${log4j.version}</version>
             <scope>test</scope>
         </dependency>
-        <!-- use cdc bundled jar for kafka connect class-->
-        <dependency>
-            <groupId>org.apache.flink</groupId>
-            <artifactId>flink-sql-connector-mysql-cdc</artifactId>
-            <version>${flink.sql.cdc.version}</version>
-            <scope>provided</scope>
-            <exclusions>
-                <exclusion>
-                    <artifactId>flink-shaded-guava</artifactId>
-                    <groupId>org.apache.flink</groupId>
-                </exclusion>
-            </exclusions>
-        </dependency>
-        <dependency>
-            <groupId>org.apache.flink</groupId>
-            <artifactId>flink-sql-connector-oracle-cdc</artifactId>
-            <version>${flink.sql.cdc.version}</version>
-            <scope>provided</scope>
-            <exclusions>
-                <exclusion>
-                    <artifactId>flink-shaded-guava</artifactId>
-                    <groupId>org.apache.flink</groupId>
-                </exclusion>
-            </exclusions>
-        </dependency>
-        <dependency>
-            <groupId>org.apache.flink</groupId>
-            <artifactId>flink-sql-connector-postgres-cdc</artifactId>
-            <version>${flink.sql.cdc.version}</version>
-            <scope>provided</scope>
-            <exclusions>
-                <exclusion>
-                    <artifactId>flink-shaded-guava</artifactId>
-                    <groupId>org.apache.flink</groupId>
-                </exclusion>
-            </exclusions>
-        </dependency>
-        <dependency>
-            <groupId>org.apache.flink</groupId>
-            <artifactId>flink-sql-connector-sqlserver-cdc</artifactId>
-            <version>${flink.sql.cdc.version}</version>
-            <scope>provided</scope>
-            <exclusions>
-                <exclusion>
-                    <artifactId>flink-shaded-guava</artifactId>
-                    <groupId>org.apache.flink</groupId>
-                </exclusion>
-            </exclusions>
-        </dependency>
-        <dependency>
-            <groupId>org.apache.flink</groupId>
-            <artifactId>flink-sql-connector-db2-cdc</artifactId>
-            <version>${flink.sql.cdc.version}</version>
-            <scope>provided</scope>
-            <exclusions>
-                <exclusion>
-                    <artifactId>flink-shaded-guava</artifactId>
-                    <groupId>org.apache.flink</groupId>
-                </exclusion>
-            </exclusions>
-        </dependency>
-        <dependency>
-            <groupId>org.apache.flink</groupId>
-            <artifactId>flink-sql-connector-mongodb-cdc</artifactId>
-            <!-- the dependency is available only for stable releases. -->
-            <version>${flink.sql.cdc.version}</version>
-            <scope>provided</scope>
-            <exclusions>
-                <exclusion>
-                    <artifactId>flink-shaded-guava</artifactId>
-                    <groupId>org.apache.flink</groupId>
-                </exclusion>
-            </exclusions>
-        </dependency>
-        <!-- add drivers for FLINK-35055 -->
         <dependency>
             <groupId>mysql</groupId>
             <artifactId>mysql-connector-java</artifactId>
             <version>${mysql.driver.version}</version>
             <scope>test</scope>
         </dependency>
-        <dependency>
-            <groupId>com.oracle.ojdbc</groupId>
-            <artifactId>ojdbc8</artifactId>
-            <version>${ojdbc.version}</version>
-            <scope>provided</scope>
-        </dependency>
-        <!-- flink cdc end -->
         <dependency>
             <groupId>org.apache.flink</groupId>
             <artifactId>flink-runtime-web</artifactId>

diff --git a/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisConfigOptions.java b/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisConfigOptions.java
@@ -43,7 +43,7 @@
 @PublicEvolving
 public class DorisConfigOptions {
 
-    public static final String IDENTIFIER = "doris";
+    public static final String IDENTIFIER = "selectdb-preview";
     // common option
     public static final ConfigOption<String> FENODES =
             ConfigOptions.key("fenodes")

diff --git a/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/CdcTools.java b/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/CdcTools.java