Skip to content

Commit

Permalink
[cdc-debug] Add cdc-debug module.
Browse files Browse the repository at this point in the history
  • Loading branch information
@joyCurry30
joyCurry30 committed Dec 11, 2023
1 parent a1e60e4 commit b481274
Show file tree
Hide file tree
Showing 3 changed files with 101 additions and 0 deletions.
88 changes: 88 additions & 0 deletions flink-cdc-debug/pom.xml
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,88 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>com.ververica</groupId>
<artifactId>flink-cdc-connectors</artifactId>
<version>3.0-SNAPSHOT</version>
</parent>

<artifactId>flink-cdc-debug</artifactId>

<properties>
<maven.compiler.source>8</maven.compiler.source>
<maven.compiler.target>8</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>

<dependencies>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-simple</artifactId>
<version>${slf4j.version}</version>
</dependency>
<!-- Apache Flink dependencies -->
<!-- These dependencies are test, because they should not be packaged into the JAR file. -->
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-common</artifactId>
<version>${flink.version}</version>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-connector-base</artifactId>
<version>${flink.version}</version>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-api-java-bridge</artifactId>
<version>${flink.version}</version>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-core</artifactId>
<version>${flink.version}</version>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-streaming-java</artifactId>
<version>${flink.version}</version>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-clients</artifactId>
<version>${flink.version}</version>
</dependency>

<!-- Flink CDC dependencies -->
<dependency>
<groupId>com.ververica</groupId>
<artifactId>flink-cdc-common</artifactId>
<version>${revision}</version>
</dependency>
<dependency>
<groupId>com.ververica</groupId>
<artifactId>flink-cdc-runtime</artifactId>
<version>${revision}</version>
</dependency>
<dependency>
<groupId>com.ververica</groupId>
<artifactId>flink-cdc-cli</artifactId>
<version>${revision}</version>
</dependency>
<dependency>
<groupId>com.ververica</groupId>
<artifactId>flink-cdc-composer</artifactId>
<version>${revision}</version>
</dependency>

<!--Flink CDC Connectors Dependencies-->
<dependency>
<groupId>com.ververica</groupId>
<artifactId>flink-cdc-pipeline-connector-values</artifactId>
<version>${project.version}</version>
</dependency>
</dependencies>
</project>
12 changes: 12 additions & 0 deletions flink-cdc-debug/src/main/java/com/ververica/cdc/debug/DebugEntry.java
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,12 @@
package com.ververica.cdc.debug;

import com.ververica.cdc.cli.CliFrontend;

public class DebugEntry {
public static void main(String[] args) throws Exception {
String jobPath = "/Users/lapata/clickzetta_jobs/flink-cdc-3.0/mysqlToDoris.yml";
String[] extArgs = {jobPath, "--use-mini-cluster", "true"};

CliFrontend.main(extArgs);
}
}
1 change: 1 addition & 0 deletions pom.xml
View file
Original file line number Diff line number Diff line change
Expand Up @@ -38,6 +38,7 @@ under the License.
<module>flink-cdc-connect</module>
<module>flink-cdc-runtime</module>
<module>flink-cdc-e2e-tests</module>
<module>flink-cdc-debug</module>
</modules>

<licenses>
Expand Down

0 comments on commit b481274

Please sign in to comment.