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

flink1.18.0的jdbc包有吗?

flink1.18.0的jdbc包有吗?我看官网有的是flink-connector-jdbc-3.0.0-1.16.jar这个的包,我连接MySQL的时候报错了:[ERROR] Could not execute SQL statement. Reason:
javax.net.ssl.SSLHandshakeException: No appropriate protocol (protocol is disabled or cipher suites are inappropriate)

展开
收起
真的很搞笑 2023-12-10 17:38:27 79 0
2 条回答
写回答
取消 提交回答
  • 这个应该是在url后面加个ssl参数就行吧 'connector' = 'mysql-cdc',
    'hostname' = 'localhost',
    'port' = '3306',
    'username' = 'root',
    'password' = '123456',
    'database-name' = 'mydb',
    'table-name' = 'orders',
    'useSSL' = 'false',
    4cffcfd0eb8028db9192e3e30cc27adf.png
    ,此回答整理自钉群“【③群】Apache Flink China社区”

    2023-12-11 22:25:41
    赞同 展开评论 打赏
  • 面对过去,不要迷离;面对未来,不必彷徨;活在今天,你只要把自己完全展示给别人看。

    Flink 1.18.0 的 jdbc 包中确实包含了 flink-connector-jdbc-3.0.0-1.16.jar 这个版本。关于您遇到的错误,javax.net.ssl.SSLHandshakeException: No appropriate protocol (protocol is disabled or cipher suites are inappropriate),这个错误通常是由于 SSL/TLS 协议或密码套件不匹配导致的。

    要解决这个问题,您可以尝试以下方法:

    1. 确保您的 Flink 和 JDBC 驱动程序的版本兼容。您可以查看官方文档以获取有关兼容性的信息。

    2. 检查您的 MySQL 服务器配置,确保它支持所需的 SSL/TLS 协议和密码套件。您可以在 MySQL 配置文件(例如 my.cnf 或 my.ini)中设置这些选项。

    3. 如果问题仍然存在,您可以尝试使用不同的 SSL/TLS 协议或密码套件。这可以通过在连接字符串中添加 sslProtocolsslCipherSuites 参数来实现。例如:

    String url = "jdbc:mysql://localhost:3306/mydb?useSSL=true&sslProtocol=TLSv1.2&sslCipherSuites=HIGH:!aNULL:!kRSA:!PSK:!MD5";
    
    2023-12-11 13:29:36
    赞同 展开评论 打赏

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

相关产品

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

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