使用FlinkStream方式从mysql同步到另一个mysql，无法完成数据同步。

[StoneMa]

程序如下：

程序一直在运行，但是source库中的tests表中的数据，无法同步到target库的testt表中

mysql binlog已经开启

[StoneMa]

invoke方法没有被调用，请问是哪里的问题呢？

[gtk96]

@StoneMa 你试一下这个 demo 是 mysql to mysql 的示例，我本地测试是 ok 的https://github.com/SophiaData/Bigdata_Code_Tutorial/blob/master/sync_database_mysql/src/main/java/io/sophiadata/flink/sync/FlinkSqlWDS.java