flink 写入 starrocks 报错

报错信息如下,请问下是什么问题导致的
{“Status”:“Fail”,“BeginTxnTimeMs”:0,“Message”:“Cancelled FileScanNode::scanner_scan”,“NumberUnselectedRows”:0,“CommitAndPublishTimeMs”:0,“Label”:“7b4547d5-350e-4052-9af5-25f917f9e8af”,“LoadBytes”:361161067,“StreamLoadPutTimeMs”:14,“NumberTotalRows”:0,“WriteDataTimeMs”:61011,“TxnId”:211765,“LoadTimeMs”:61026,“ReadDataTimeMs”:340,“NumberLoadedRows”:0,“NumberFilteredRows”:0}

W1116 19:11:07.295277 9245 stream_load_executor.cpp:89] fragment execute failed, query_id=1c43f545f8f79b2b-2cd45264190d02af, err_msg=Cancelled FileScanNode::get_next, id=1c43f545f8f79b2b-2cd45264190d02af, job_id=-1, txn_id: 215860, label=a9708156-30bb-4302-a500-e0cca337a3fe, db=ilad_sig

你是几个导入失败了?上面那个和下面那个不是一个事务,你根据txn_id找下be的warn日志

根据这个排查流程 问题排查流程--导入 排查到be 的日志中如下:

warning 日志:

W1116 11:17:00.939889 7005 stream_load_executor.cpp:89] fragment execute failed, query_id=7d4bfb38082ee6d1-55d35fb4ad1b0987, err_msg=Cancelled FileScanNode::scanner_scan, id=7d4bfb38082ee6d1-55d35fb4ad1b0987, job_id=-1, txn_id: 211765, label=7b4547d5-350e-4052-9af5-25f917f9e8af, db=ilad_sig

您发的截图里面都不是一个label或者txn了,麻烦根据7b4547d5-350e-4052-9af5-25f917f9e8af(label_id)到be.WARNNING日志里面grep一下截个图看看

label重复了,换个自定义label名或者不指定自动生成下再跑load任务看看

不是很懂你说的这些概念,我重启下 flink 的导入任务?

嗯你重启试试,要是再报错直接截下图看看