Flink CDC 中，Sink: clean_commits 步骤的并行度

Flink CDC 中，Sink: clean_commits 步骤的并行度是由 Hudi 控制台配置决定的。您可以通过以下方式修改 Hudi 控制台的配置：

1. 打开 Hudi 控制台，找到 "hive-site.xml" 文件。

2. 在文件中添加以下配置项：

   <property>
     <name>hoodie.datasource.write.recordkey.field</name>
     <value>your_record_key_field</value>
   </property>
   <property>
     <name>hoodie.datasource.write.partitionpath.field</name>
     <value>your_partition_path_field</value>
   </property>
   <property>
     <name>hoodie.datasource.write.table.type</name>
     <value>COPY_ON_WRITE</value>
   </property>
   <property>
     <name>hoodie.datasource.write.operation</name>
     <value>insert</value>
   </property>
   <property>
     <name>hoodie.datasource.write.parallelism</name>
     <value>5</value>
   </property>
   

   其中，your_record_key_field 和 your_partition_path_field 分别表示您的记录键字段和分区路径字段。将 hoodie.datasource.write.parallelism 的值设置为您想要的并行度。

3. 保存并重启 Hudi 服务。
4. 重新运行 Flink CDC 任务，Sink: clean_commits 步骤的并行度应该会根据您的配置改变。