[Bug] [starrocks] 写数据到starrocks出错但却显示成功
- Dominant language
- Java
- Stars
- 4.1k
- Forks
- 1.7k
- PR merge metrics
- No merged PRs in 30d
Description
### Search before asking
- [X] I had searched in the [issues](https://github.com/DTStack/chunjun/issues) and found no similar issues.
### What happened
输入源有700多条数据,flink消费了一次就消费完输入源的数据,当一次将这些数据写入sr时报错,但任务却显示成功
[tasklog.log](https://github.com/DTStack/chunjun/files/12191176/tasklog.log)
### What you expected to happen
写数据报错时应触发相对应的反应
### How to reproduce
1. 读写数据只需要一次就完成任务
2. 写出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](https://www.apache.org/foundation/policies/conduct)
Contributor guide
Assessment
This issue has not been assessed yet.