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

Flink CDC中这个报错要怎么处理呀 ?

Flink CDC中这个报错要怎么处理呀 在webui看不到日志。
c1f269648a1ae8542200d58ff970076d.png
org.apache.flink.util.FlinkException: The file STDOUT does not exist on the TaskExecutor

展开
收起
小易01 2023-08-16 08:03:10 195 0
1 条回答
写回答
取消 提交回答
  • Flink CDC 读取 MySQL 时,如果出现 java.lang.ClassNotFoundException: com.mysql.jdbc.Driver 错误,可能是因为没有安装 MySQL 的 JDBC 驱动。

    要解决这个问题,需要安装 MySQL 的 JDBC 驱动,并将驱动的 jar 包添加到 Flink 的 lib 目录中。

    如果您使用的是 Maven,可以通过以下方式添加 MySQL 的 JDBC 驱动:


    mysql
    mysql-connector-java
    8.0.21

    如果您使用的是 Gradle,可以通过以下方式添加 MySQL 的 JDBC 驱动:

    dependencies {
    compile 'mysql:mysql-connector-java:8.0.21'
    }
    添加 MySQL 的 JDBC 驱动后,重新启动 Flink 即可。

    2023-09-26 10:34:51
    赞同 展开评论 打赏

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

相关产品

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

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