百岁

oracle -> mysql 

代码有了，但是还没有测试通过，oracle的 实时日志监听配置有点麻烦

收到，会在后续版本中完善该功能

嗯 ，在下一个版本中，会开通flink checkpoint功能，这样就会依赖于flink-cdc的operator state中记录的mysql binlog消费偏移量，恢复时自动从记录的偏移量开始消费

could you provide ddl of source table creation, and source, target db type

``` shell Caused by: java.lang.RuntimeException: java.lang.RuntimeException: java.lang.InstantiationException: java.lang.NoClassDefFoundError: com/qlangtech/tis/realtime/DefaultFlinkSourceHandle at com.qlangtech.plugins.incr.flink.TISFlinkClassLoaderFactory.lambda$buildClientLoaderFactory$1(TISFlinkClassLoaderFactory.java:120) at org.apache.flink.client.ClientUtils.buildUserCodeClassLoader(ClientUtils.java:87) at org.apache.flink.client.program.PackagedProgram.(PackagedProgram.java:145) at org.apache.flink.client.program.PackagedProgram.(PackagedProgram.java:65) at org.apache.flink.client.program.PackagedProgram$Builder.build(PackagedProgram.java:691) at com.qlangtech.tis.plugins.flink.client.FlinkClient.submitJar(FlinkClient.java:80) at com.qlangtech.plugins.incr.flink.launch.FlinkTaskNodeController.deploy(FlinkTaskNodeController.java:179) at com.qlangtech.plugins.incr.flink.launch.FlinkTaskNodeController.deploy(FlinkTaskNodeController.java:144) at com.qlangtech.tis.coredefine.module.action.TISK8sDelegate.deploy(TISK8sDelegate.java:136) at com.qlangtech.tis.coredefine.module.action.CoreAction.doDeployIncrSyncChannal(CoreAction.java:569) ......

can you make command ping available `ping mvn-repo.oss-cn-hangzhou.aliyuncs.com`

+1 great

已经利用chunjun实现了

comlete