Paddy Gu
Paddy Gu
In my opinion, this code does not need to be modified. This code works fine in my environment,The mysql DateTime type should correspond to the java.sql.Timestamp. What version of mysql...
可以使用hdfs插件,可以支持多并行度
保持环境变量和CHUNJUN-DIST目录结构和我的一致,应该是没有问题的
> 你需要start-cluster.sh 之前,把chunjun 的全部jar包移动或者复制到flink lib的目录下,这样才能找到。 你可以把之前的taskmanager用 stop-cluster.sh 关掉,再执行上述操作试下。 现在存在日志类冲突的问题,我试过直接放上去会没有日志
Error caused by duplicate primary keys
看图上并行度是10 可以提供一下具体的报错信息么
断点续传是指作业失败的时候,从指定的checkpoint进行恢复。相关的知识点可以查阅文档:https://dtstack.github.io/chunjun/documents/f29c0d86-f41a-5de1-a705-6dc2b6df91fb 从你的描述中无法判断你是想要断点续传还是想要做增量同步 增量同步文档:https://dtstack.github.io/chunjun/documents/d1b20bf7-fab2-5a56-8f4d-6fb13ce9fec0
增量同步具体用法可以看一下文档,不依赖taier的话需要手动填写一下startlocation
建议用最新的版本跑一下 新版本对性能有过一次优化