chunjun
chunjun copied to clipboard
[Bug] [starrocks] 写数据到starrocks出错但却显示成功
Search before asking
- [X] I had searched in the issues and found no similar issues.
What happened
输入源有700多条数据,flink消费了一次就消费完输入源的数据,当一次将这些数据写入sr时报错,但任务却显示成功 tasklog.log
What you expected to happen
写数据报错时应触发相对应的反应
How to reproduce
- 读写数据只需要一次就完成任务
- 写出sr时报错
Anything else
出现问题的原因分析: starrocks连接器写数据时,会启动一个子线程异步的刷新数据到输出源,当刷新数据报错时,因为是子线程所以主线程获取不了此报错,导致任务结束后没有返回异常。虽然将异常信息赋给了成员变量,但只有当下一次刷新数据时,主线程才能捕获此异常,进而将触发任务级的报错。但当只消费一次数据数据源就消费完成时,无法触发主线程捕获此异常导致任务虽然失败,但是却显示成功。
Version
master
Are you willing to submit PR?
- [X] Yes I am willing to submit a PR!
Code of Conduct
- [X] I agree to follow this project's Code of Conduct