Flinkx读取mysql中途失败,任务却显示成功
- Dominant language
- Java
- Stars
- 4.1k
- Forks
- 1.7k
- PR merge metrics
- No merged PRs in 30d
Description
1.我们的mysql可能有问题(我们还在排查mysql的问题)
2.我们使用mysql to mysql 进行数据同步
3.在yarn上,任务显示正常,但是sink端数据条数和source端数据条数不一致
4.然后用local模式,测试mysql to mysql 发现异常

5.然后我排查flinkx代码发现有个bug,在执行next发生异常时,默认已经把source读取完成了,没有数据可以读取了。然后导致任务成功了。


**效果就是mysql source发生了异常,但是还是导致flinkx任务成功了**
6.我们的修改如下

Contributor guide
Assessment
This issue has not been assessed yet.