You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by 海天一色 <10...@qq.com> on 2021/04/15 07:56:53 UTC
mysql-cdc 无法显示源表数据的问题

hi:
&nbsp; 在学习实践 pyflink（1.12.0v）的mysql-cdc模式时遇到数据无法显示的问题，烦请大牛们看看啥原因
&nbsp;&nbsp;
&nbsp; 源头数据库是mysql（5.7 v）的，已经打开了binlog模式，源数据表定义如下&nbsp; &nbsp;&nbsp;
&nbsp; CREATE TABLE test (
&nbsp; &nbsp; &nbsp; &nbsp; id int,
&nbsp; &nbsp; &nbsp; &nbsp; name string,
&nbsp; &nbsp; &nbsp; &nbsp; age int,&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&nbsp;
&nbsp; &nbsp; &nbsp; &nbsp; PRIMARY KEY (id) NOT ENFORCED&nbsp; &nbsp; &nbsp; &nbsp;&nbsp;
&nbsp; &nbsp; &nbsp; &nbsp; ) WITH (
&nbsp; &nbsp; &nbsp; &nbsp; 'connector' = 'mysql-cdc',
&nbsp; &nbsp; &nbsp; &nbsp; 'hostname' = '10.11.33.195',
&nbsp; &nbsp; &nbsp; &nbsp; 'port' = '3306',
&nbsp; &nbsp; &nbsp; &nbsp; 'username' = 'root',
&nbsp; &nbsp; &nbsp; &nbsp; 'password' = 'ha@123',
&nbsp; &nbsp; &nbsp; &nbsp; 'server-id' = '123',
&nbsp; &nbsp; &nbsp; &nbsp; 'database-name' = 'mysql',
&nbsp; &nbsp; &nbsp; &nbsp; 'table-name' = 'zk_test'&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&nbsp;
&nbsp; &nbsp; &nbsp; &nbsp; )&nbsp;
&nbsp; &nbsp; &nbsp; &nbsp;&nbsp;
&nbsp; &nbsp;显示源表数据的代码
&nbsp; &nbsp;t_env.execute_sql('select id,name,age from test where id &gt; 0').print()
&nbsp; &nbsp;
&nbsp; &nbsp;
&nbsp; &nbsp;服务器上提交python脚本执行后，显示如下&nbsp;&nbsp;
+----+-------------+--------------------------------+-------------+
| op |&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; id |&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;name |&nbsp; &nbsp; &nbsp; &nbsp; &nbsp;age |
+----+-------------+--------------------------------+-------------+
Apr 15, 2021 2:27:15 PM com.github.shyiko.mysql.binlog.BinaryLogClient connect
INFO: Connected to 10.11.33.195:3306 at mysql-bin.000001/10303 (sid:123, cid:87)&nbsp;


&nbsp; 源头mysql库的zk_test表里有几条数据，但就是无法显示出来，数据库表插入新记录后也没有数据显示出来
&nbsp; lib目录已经放置了相关&nbsp;connector.jar 包