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 470 分享 版权
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 集群和引擎,提高作业开发运维效率。

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