chunjun icon indicating copy to clipboard operation
chunjun copied to clipboard

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

Open david-gao1 opened this issue 2 years ago • 0 comments

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

  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

david-gao1 avatar Jul 28 '23 07:07 david-gao1