Flink CDC通過將源數(shù)據(jù)變更事件轉(zhuǎn)換為Flink可消費的數(shù)據(jù)流，然后使用Flink的API提交到Flink集群進行實時處理。

在Flink CDC中，提交方式可以通過以下步驟將數(shù)據(jù)提交到Flink：

創(chuàng)新互聯(lián)公司公司2013年成立，先為驛城等服務(wù)建站，驛城等地企業(yè)，進行企業(yè)商務(wù)咨詢服務(wù)。為驛城企業(yè)網(wǎng)站制作PC+手機+微官網(wǎng)三網(wǎng)同步一站式服務(wù)解決您的所有建站問題。

1、創(chuàng)建Flink StreamExecutionEnvironment：

```java

StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

```

2、設(shè)置并行度：

```java

env.setParallelism(1); // 設(shè)置并行度為1，可以根據(jù)需求進行調(diào)整

```

3、添加數(shù)據(jù)源：

```java

FlinkCDCSource source = new FlinkCDCSource<>(...); // 根據(jù)具體數(shù)據(jù)源進行實例化

```

4、添加轉(zhuǎn)換操作：

```java

source.addSink(new MySinkFunction()); // 自定義的Sink函數(shù)，用于處理數(shù)據(jù)

```

5、執(zhí)行任務(wù)：

```java

env.execute("Flink CDC Job"); // 執(zhí)行任務(wù)，并指定任務(wù)名稱

```

以上是一個簡單的示例，展示了如何將Flink CDC中的提交方式應(yīng)用到Flink中，具體的實現(xiàn)會根據(jù)不同的數(shù)據(jù)源和業(yè)務(wù)需求而有所不同。

相關(guān)問題與解答：

問題1：如何在Flink CDC中指定數(shù)據(jù)的讀取位置？

答：在Flink CDC中，可以使用CheckpointedPosition來指定數(shù)據(jù)的讀取位置，通過CheckpointedPosition可以記錄上一次讀取的位置，并在下一次啟動時從該位置繼續(xù)讀取數(shù)據(jù)，具體的實現(xiàn)可以參考Flink CDC的文檔或示例代碼。

問題2：如何在Flink CDC中處理讀取到的數(shù)據(jù)？

答：在Flink CDC中，可以使用自定義的Sink函數(shù)來處理讀取到的數(shù)據(jù)，Sink函數(shù)可以對數(shù)據(jù)進行過濾、轉(zhuǎn)換、聚合等操作，以滿足業(yè)務(wù)需求，具體的實現(xiàn)可以根據(jù)具體的需求編寫相應(yīng)的Sink函數(shù)，并將其添加到數(shù)據(jù)源中。

本文題目：FlinkCDC里這種提交方式怎么提交到flink？
新聞來源：http://uogjgqi.cn/article/dpgiics.html