开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

"Flink CDC这是什么原因导致得SLINK ?

"Flink CDC这是什么原因导致得SLINK ?
ef9cd6d2bba19367b29ed81714a92d77.png
d9410e09c3d6af9ee6e5fb039356e734.png
e1324a007950b1569bffba38dc3acd17.png
033abcdb1d1cf5993c3992ffb1efb53a.png
60a47ba235ff1a46a6695e1965320306.png
插入数据
1a776b5701be25d6b17e9dd176530059.png
9ea2bc325009feebcf84dee44ad99b68.png"

展开
收起
小易01 2023-07-24 21:36:55 80 0
3 条回答
写回答
取消 提交回答
  • 北京阿里云ACE会长

    Flink CDC 出现问题的原因,供您参考:
    配置不正确:如果 Flink CDC 的配置不正确,可能会导致任务无法正常启动或运行,从而出现问题。建议检查 Flink CDC 的配置是否正确,并根据实际情况进行调整。
    数据源的变化:如果数据源发生变化,例如表结构发生变化或数据类型发生变化,可能会导致 Flink CDC 无法正确地采集和处理数据,从而出现问题。建议在数据源发生变化时,及时检查和调整 Flink CDC 的配置。
    并发度设置不正确:如果并发度设置得过高或过低,可能会导致资源浪费或任务延迟,从而出现问题。建议根据实际情况调整并发度设置,以获得最佳的性能和吞吐量。
    资源不足:如果 Flink 集群的资源不足,例如内存、CPU 或网络带宽,可能会导致 Flink CDC 无法正常运行,从而出现问题。建议检查 Flink 集群的资源使用情况,并根据实际情况进行调整。
    代码错误:如果编写的 Flink CDC 代码存在错误,例如语法错误、逻辑错误或算法错误,可能会导致任务无法正常运行,从而出现问题。建议在编写代码时,仔细检查代码逻辑和语法,并进行充分的测试和调试。

    2023-07-29 18:50:41
    赞同 展开评论 打赏
  • 意中人就是我呀!

    "ckp失败,你1s一次太大了,3-10分钟都行。1s一次ckp,6s做不了就抛弃。太小了,调大点。
    图片.png
    此回答整理至钉群“Flink CDC 社区”"

    2023-07-26 11:27:27
    赞同 展开评论 打赏
  • 存在即是合理

    出现了一个FlinkRuntimeException异常,该异常的原因是超过了检查点可容忍失败阈值。
    在代码中,出现异常的地方是在CheckpointFailureManager类的98行和84行。这个异常是由于检查点失败而引起的,检查点失败是由于在检查点过程中发生了某些错误。
    具体来说,检查点失败有两种情况:一种是任务级别的检查点失败,另一种是全局级别的检查点失败。任务级别的检查点失败是由于任务在执行过程中发生了错误,导致无法继续执行,从而导致检查点失败。全局级别的检查点失败是由于整个任务集群在执行过程中发生了错误,导致无法继续执行,从而导致检查点失败。
    在这个代码中,可能是由于任务级别的检查点失败导致的异常。具体的原因可能是由于任务在执行过程中发生了某些错误,导致无法继续执行,从而导致检查点失败。
    总之,这个异常是由于Flink在执行检查点过程中发生了错误而引起的,需要进一步调查和解决。

    2023-07-25 18:41:31
    赞同 展开评论 打赏

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

相关产品

  • 实时计算 Flink版
  • 热门讨论

    热门文章

    相关电子书

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载