mysqlCDC运行报错 ERROR com.zaxxer.hikari.pool.HikariPool - connection-pool-s201:3306 - Exception during pool initialization. #1477
Unanswered
frankandroid
asked this question in
Q&A
Replies: 0 comments
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
-
mysql版本:5.7.16
用的connector版本是8.0.16
mysql
mysql-connector-java
8.0.16
按照wiki代码运行报错[flink-akka.actor.default-dispatcher-6] ERROR com.zaxxer.hikari.pool.HikariPool - connection-pool-s201:3306 - Exception during pool initialization.
mysql可正常连接访问,但是运行代码报错
// TODO 1. 准备流处理环境
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
env.setParallelism(1);
// TODO 3. 创建 Flink-MySQL-CDC 的 Source
MySqlSource mySqlSource = MySqlSource.builder()
.hostname("s201")
.port(3306)
.databaseList("gmall") // set captured database
.tableList("gmall.activity_info") // set captured table
.username("root")
.password("000000")
.deserializer(new JsonDebeziumDeserializationSchema()) // converts SourceRecord to JSON String
.startupOptions(StartupOptions.initial())
.build();
Beta Was this translation helpful? Give feedback.
All reactions