diff --git a/flink-cdc-debug/pom.xml b/flink-cdc-debug/pom.xml new file mode 100644 index 00000000000..d5a47c28798 --- /dev/null +++ b/flink-cdc-debug/pom.xml @@ -0,0 +1,88 @@ + + + 4.0.0 + + com.ververica + flink-cdc-connectors + 3.0-SNAPSHOT + + + flink-cdc-debug + + + 8 + 8 + UTF-8 + + + + + org.slf4j + slf4j-simple + ${slf4j.version} + + + + + org.apache.flink + flink-table-common + ${flink.version} + + + org.apache.flink + flink-connector-base + ${flink.version} + + + org.apache.flink + flink-table-api-java-bridge + ${flink.version} + + + org.apache.flink + flink-core + ${flink.version} + + + org.apache.flink + flink-streaming-java + ${flink.version} + + + org.apache.flink + flink-clients + ${flink.version} + + + + + com.ververica + flink-cdc-common + ${revision} + + + com.ververica + flink-cdc-runtime + ${revision} + + + com.ververica + flink-cdc-cli + ${revision} + + + com.ververica + flink-cdc-composer + ${revision} + + + + + com.ververica + flink-cdc-pipeline-connector-values + ${project.version} + + + \ No newline at end of file diff --git a/flink-cdc-debug/src/main/java/com/ververica/cdc/debug/DebugEntry.java b/flink-cdc-debug/src/main/java/com/ververica/cdc/debug/DebugEntry.java new file mode 100644 index 00000000000..e1e15de57eb --- /dev/null +++ b/flink-cdc-debug/src/main/java/com/ververica/cdc/debug/DebugEntry.java @@ -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); + } +} diff --git a/pom.xml b/pom.xml index 43297e2408c..bb4622e1cf5 100644 --- a/pom.xml +++ b/pom.xml @@ -38,6 +38,7 @@ under the License. flink-cdc-connect flink-cdc-runtime flink-cdc-e2e-tests + flink-cdc-debug