大数据侠客的博客针对mysql8.0报错:com.mysql.jdbc.exceptions.jdbc4.MySQLNonTransientConnectionException: Could not creat。原来用的是5.1.37的驱动。数据库是mysql5.7,可以连接成功。换成了下边这个驱动就OK了。瞬间心情好了...
大数据菜鸡一号的博客flinksql cdc 连接kafka报错 org.apache.flink.table.api.ValidationException: Unable to create a sink for writing table 'default_catalog.default_database.kafka_mysql_cdc'.