似乎存在一些语法错误和格式问题。正确的 JDBC URL 格式应该是:
Copy
jdbc:mysql://:/?=&=...
其中:
表示 MySQL 服务器的主机名或 IP 地址;
表示 MySQL 服务器的端口号,通常为 3306;
表示要连接的数据库名称;
和 表示连接参数的键值对,多个参数之间使用 & 符号连接。
因此,您可以尝试将您提供的 JDBC URL 修改为以下格式:
Copy
jdbc:mysql://118.2.64.3306/dbname?serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true&useSSL=false
其中,dbname 表示要连接的数据库名称,serverTimezone、allowPublicKeyRetrieval 和 useSSL 是一些常用的连接参数,您可以根据实际需求进行调整。需要注意的是,JDBC URL 中的所有参数都需要用 & 符号连接,不要使用空格或其他分隔符。
另外,建议您在创建 JDBC Sink 表时,还需指定正确的用户名和密码,以确保能够成功连接到 MySQL 数据库。例如:
scheme
Copy
CREATE TABLE allusers (
id INT,
name STRING,
age INT
) WITH (
'connector.type' = 'jdbc',
'connector.url' = 'jdbc:mysql://118.2.64.3306/dbname?serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true&useSSL=false',
'connector.table' = 'allusers',
'connector.username' = '',
'connector.password' = ''
)
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。