[I] [Bug] No mysql-sync-table action in paimon-action-1.3.1.jar [paimon]

["uniorder (via GitHub)" <gi...@apache.org>]

uniorder opened a new issue, #7058:
URL: https://github.com/apache/paimon/issues/7058

   ### Search before asking
   
   - [x] I searched in the [issues](https://github.com/apache/paimon/issues) and found nothing similar.
   
   
   ### Paimon version
   
   Hello:
   
   I'm trying to follow the demo for run first application, but I got an error like:
   
   ```txt
   /app/flink-2.2.0# ./bin/flink run \
       ./app/paimon-flink-action-1.3.1.jar \
       mysql_sync_table \
       --warehouse hdfs:///app/paimon/warehouse \
       --database ods_db \
       --table ods_foo \
       --partition_keys pt \
       --primary_keys pt,uid \
       --computed_column '_month=month(created_at)' \
       --mysql_conf hostname=10.0.171.137 \
       --mysql_conf username=root \
       --mysql_conf password=test01 \
       --mysql_conf database-name='mysql_cdc_test' \
       --mysql_conf table-name='foo' \
       --table_conf bucket=4 \
       --table_conf changelog-producer=input \
       --table_conf sink.parallelism=4
   Usage: <action> [OPTIONS]
   
   Available actions:
     copy_files
     compact
     compact_database
     drop_partition
     delete
     merge_into
     rollback_to
     rollback_to_timestamp
     create_tag
     create_tag_from_timestamp
     create_tag_from_watermark
     delete_tag
     expire_tags
     replace_tag
     reset_consumer
     migrate_table
     migrate_database
     remove_orphan_files
     query_service
     expire_partitions
     mark_partition_done
     create_branch
     delete_branch
     fast_forward
     rename_tag
     repair
     rewrite_file_index
     expire_snapshots
     expire_changelogs
     remove_unexisting_files
     clear_consumers
     rescale
     clone
   For detailed options of each action, run <action> --help
   
   ------------------------------------------------------------
    The program finished with the following exception:
   
   org.apache.flink.client.program.ProgramInvocationException: The main method caused an error: Unknown action "mysql_sync_table".
   	at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:360)
   	at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:223)
   	at org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:105)
   	at org.apache.flink.client.cli.CliFrontend.executeProgram(CliFrontend.java:1017)
   	at org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:230)
   	at org.apache.flink.client.cli.CliFrontend.parseAndRun(CliFrontend.java:1261)
   	at org.apache.flink.client.cli.CliFrontend.lambda$mainInternal$11(CliFrontend.java:1355)
   	at org.apache.flink.runtime.security.contexts.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:28)
   	at org.apache.flink.client.cli.CliFrontend.mainInternal(CliFrontend.java:1355)
   	at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1323)
   Caused by: java.lang.UnsupportedOperationException: Unknown action "mysql_sync_table".
   	at org.apache.paimon.flink.action.ActionFactory.createAction(ActionFactory.java:76)
   	at org.apache.paimon.flink.action.FlinkActions.main(FlinkActions.java:38)
   	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
   	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
   	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
   	at java.base/java.lang.reflect.Method.invoke(Method.java:569)
   	at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:343)
   	... 9 more
   
   ```
   
   It seems like not mysql-sync-table action in that jar.
   
   So, am I use wrong version?
   
   thanks.
   
   ### Compute Engine
   
   Flink: 2.2.0
   
   ### Minimal reproduce step
   
   follow the first step about paimon mysql cdc here: https://paimon.apache.org/docs/1.3/cdc-ingestion/mysql-cdc/
   
   ### What doesn't meet your expectations?
   
   Can not be running.
   
   ### Anything else?
   
   _No response_
   
   ### Are you willing to submit a PR?
   
   - [ ] I'm willing to submit a PR!


-- 
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: issues-unsubscribe@paimon.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

Re: [I] [Bug] No mysql-sync-table action in paimon-action-1.3.1.jar [paimon]

["juntaozhang (via GitHub)" <gi...@apache.org>]

juntaozhang commented on issue #7058:
URL: https://github.com/apache/paimon/issues/7058#issuecomment-3882732371

   This may not be a bug. Flink CDC currently does not support Flink 2.x versions, so Paimon’s CDC functionality is currently only compatible with Flink up to version 1.20.*.
   You can try with flink 1.20.1.


-- 
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: issues-unsubscribe@paimon.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org