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

Flink CDC里 我用flink SQL 同步一张表到es。日志不动,没有报错怎么排查?

Flink CDC里 我用flink SQL 同步一张表到es。 tasks 状态 一直卡在 DEPLOYING
日志到这里就不动了:
2024-01-23 22:15:38,787 INFO com.ververica.cdc.connectors.mysql.source.assigners.MySqlSnapshotSplitAssigner [] - Split table skill_upp.job into 1 chunks, time cost: 1461ms.

没有任何报错,我该怎么排查?

展开
收起
小小鹿鹿鹿 2024-02-01 16:22:25 33 0
1 条回答
写回答
取消 提交回答
  • 面对过去,不要迷离;面对未来,不必彷徨;活在今天,你只要把自己完全展示给别人看。

    你可以尝试以下方法来排查问题:

    1. 检查Flink集群的资源是否足够。如果资源不足,可能会导致任务无法正常部署。你可以查看Flink的Web UI,了解集群的资源使用情况。

    2. 检查Elasticsearch的状态。确保Elasticsearch正常运行,并且可以正常接收数据。你可以通过访问Elasticsearch的API或者Web UI来检查其状态。

    3. 检查网络连接。确保Flink和Elasticsearch之间的网络连接正常,没有阻塞或延迟。

    4. 查看Flink的日志。在Flink的日志中,可能会有更详细的错误信息。你可以在Flink的配置文件中设置日志级别为DEBUG,以便获取更多的调试信息。

    5. 尝试重启Flink作业。有时候,重启作业可能会解决一些未知的问题。你可以先停止当前的作业,然后重新启动它。

    6. 如果以上方法都无法解决问题,你可以考虑在Flink社区寻求帮助。在GitHub上提交一个issue,详细描述你遇到的问题,并提供相关的日志和配置信息。

    2024-02-02 14:23:45
    赞同 展开评论 打赏

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

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    PostgresChina2018_赖思超_PostgreSQL10_hash索引的WAL日志修改版final 立即下载
    Kubernetes下日志实时采集、存储与计算实践 立即下载
    日志数据采集与分析对接 立即下载