homesickjava
homesickjava
I have mysqlcdc depended jar in $FLINK_HOME/lib  and I use flink to run paimon-flink-action.jar to synchronizing datas , and my command is : `./flink run -Dclassloader.check-leaked-classloader=false paimon-flink-action-0.4-SNAPSHOT.jar mysql-sync-table --warehouse...
it has data synchronizing info, however, when I use flink-sql to query, I could not get any records the script that I use: ./flink run -Dclassloader.check-leaked-classloader=false paimon-flink-action-0.4-SNAPSHOT.jar mysql-sync-table --warehouse hdfs://pcosmo-gyos03:8020/user/root/warehouse...