[Optimization-3932][cdc] Optimize CDCSOURCE and support sink print an…

…d mock
DataLinkDC · Nov 20, 2024 · d57e4ba · d57e4ba
1 parent 16add5f
commit d57e4ba
Show file tree

Hide file tree

Showing 24 changed files with 1,068 additions and 1,012 deletions.
diff --git a/dinky-admin/src/main/java/org/dinky/service/task/FlinkSqlTask.java b/dinky-admin/src/main/java/org/dinky/service/task/FlinkSqlTask.java
@@ -54,10 +54,12 @@ public FlinkSqlTask(TaskDTO task) {
 
     @Override
     public List<SqlExplainResult> explain() {
+        jobManager.setPlanMode(true);
         return jobManager.explainSql(task.getStatement()).getSqlExplainResults();
     }
 
     public ObjectNode getJobPlan() {
+        jobManager.setPlanMode(true);
         String planJson = jobManager.getJobPlanJson(task.getStatement());
         return JsonUtils.parseObject(planJson);
     }

diff --git a/dinky-cdc/dinky-cdc-core/src/main/java/org/dinky/cdc/AbstractSinkBuilder.java b/dinky-cdc/dinky-cdc-core/src/main/java/org/dinky/cdc/AbstractSinkBuilder.java
diff --git a/dinky-cdc/dinky-cdc-core/src/main/java/org/dinky/cdc/SinkBuilder.java b/dinky-cdc/dinky-cdc-core/src/main/java/org/dinky/cdc/SinkBuilder.java
@@ -32,8 +32,7 @@ public interface SinkBuilder {
 
     SinkBuilder create(FlinkCDCConfig config);
 
-    DataStreamSource<String> build(
-            CDCBuilder cdcBuilder,
+    void build(
             StreamExecutionEnvironment env,
             CustomTableEnvironment customTableEnvironment,
             DataStreamSource<String> dataStreamSource);