homesickjava commented on issue #1560: URL: https://github.com/apache/incubator-paimon/issues/1560#issuecomment-1633811290
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 hdfs://pcosmo-gyos03:8020/user/root/warehouse --database paimon_db --table paimon_sync_machine_baseinfo --mysql-conf hostname=10.206.32.3 --mysql-conf port=9006 --mysql-conf username=root --mysql-conf password=123456 --mysql-conf database-name=paimontest --mysql-conf table-name='machine_baseinfo' --catalog-conf metastore=hive --catalog-conf uri=thrift://10.206.32.3:9083 --table-conf bucket=4 --table-conf changelog-producer=input --table-conf sink.parallelism=4 ` I use both hive and flink sql-client to query paimon data of paimon_sync_machine_baseinfo . however, I got empty set of the quering, how can I synchronizing the data from mysql to paimon ~~ -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
