Flink-SQL 同步MySQL 数据 怎么设置并行度？

"建议在最外面设置，不要在sql里面设置。 此答案整理自钉群“Flink CDC 社区”"

可以通过以下两种方式设置并行度：

• 在创建 DataStreamSource 时，通过 setParallelism(int parallelism) 方法设置并行度。例如：

DataStreamSource<Tuple2<Integer, String>> source = env.addSource(new JdbcReader())
    .setParallelism(3); // 设置并行度为3

• 在 SQL 语句中使用 WITH 关键字设置并行度。例如：

WITH (
  'connector' = 'jdbc',
  'url' = 'jdbc:mysql://localhost:3306/db',
  'table-name' = 'table',
  'username' = 'user',
  'password' = 'password',
  'parallelism' = '3'  -- 设置并行度为3
) 
SELECT * FROM table

注意，并行度的设置需要根据具体的场景和硬件环境进行调整。一般来说，并行度越大，处理性能越高，但同时也会增加资源消耗和调度复杂度。