DTStack / DTStack/chunjun

[Bug] [starrocks] 写数据到starrocks出错但却显示成功

Open
#1,778 0 comments 0 reactions 0 assignees View on GitHub
bug
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

Open the contributing guide

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.