Flink CDC里 如何修复这个问题api?

Flink CDC里 如何修复这个问题api?设置了55.srouce 并行度 .setParallelism(10) 提示新的错误了
Subtask ID 4 is out of server id range 55, please adjust the server id range to make the number of server id larger than the source parallelism.
The 'server-id' in the mysql cdc connector should be globally unique, but conflicts happen now.

展开
收起
小小鹿鹿鹿 2024-04-22 20:18:21 273 分享 版权
1 条回答
写回答
取消 提交回答
  • api里面设置 serverid的 要保证唯一。读取source的并行度要比你设置的 serverid 的范围小 。4026ca8e3ce5bdaa278a2c63e53a7365.png此回答来自钉群Flink CDC 社区。

    2024-04-23 22:36:54
    赞同 1 展开评论

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

还有其他疑问?
咨询AI助理