Raven888888 opened a new issue, #31564: URL: https://github.com/apache/doris/issues/31564
### Search before asking - [X] I had searched in the [issues](https://github.com/apache/doris/issues?q=is%3Aissue) and found no similar issues. ### Version 2.0 ### What's Wrong? Create a new routine load that consumes from kafka topic with a partition and offset. Routine load state is `RUNNING` but progress is stagnant. No error log or reason of state change, but there is other message as shown (not sure if it is important)  In the BE log, ``` 116326956-W0228 16:58:34.324998 226856 data_consumer_group.cpp:178] failed to append msg to pipe. grp: cb4508d39a0e4786-8aba878d84df10a1 116327083:W0228 16:58:34.325412 226856 routine_load_task_executor.cpp:401] consuming failed, routine load task: id=732f7e3a60b948f4-a1e2d9492bcd64dd, job_id=24258401, txn_id=27288862, label=xxxxxx_data_load_123-24258401-732f7e3a60b948f4-a1e2d9492bcd64dd-27288862, elapse(s)=41, kafka, brokers: 146.59.149.182:9092, topic: xxxxxx, partition: [0: 5741422392] 116327448-W0228 16:58:34.777653 226848 fragment_mgr.cpp:145] query_id=732f7e3a60b948f4-a1e2d9492bcd64dd, instance_id=732f7e3a60b948f4-a1e2d9492bcd64de meet error status [CANCELLED]Cancelled 116327628-W0228 16:58:34.777705 226848 fragment_mgr.cpp:480] report error status: [CANCELLED]Cancelled to coordinator: TNetworkAddress(hostname=51.89.153.159, port=9020), query id: 732f7e3a60b948f4-a1e2d9492bcd64dd, instance id: 732f7e3a60b948f4-a1e2d9492bcd64de 116327881-W0228 16:58:34.777997 226848 fragment_mgr.cpp:267] Got error while opening fragment 732f7e3a60b948f4-a1e2d9492bcd64de, query id: 732f7e3a60b948f4-a1e2d9492bcd64dd: [CANCELLED]Cancelled 116328066-W0228 16:58:34.781023 226848 vtablet_sink.cpp:635] cancel node channel VNodeChannel[11247281-3762898], load_id=732f7e3a60b948f4-a1e2d9492bcd64dd, txn_id=27288862, node=51.89.233.106:8060, error message: [CANCELLED]Cancelled 116328290-W0228 16:58:34.781091 226848 vtablet_sink.cpp:635] cancel node channel VNodeChannel[11247281-1340075], load_id=732f7e3a60b948f4-a1e2d9492bcd64dd, txn_id=27288862, node=51.77.119.186:8060, error message: [CANCELLED]Cancelled 116328514-W0228 16:58:34.781117 226848 vtablet_sink.cpp:635] cancel node channel VNodeChannel[11247281-23170363], load_id=732f7e3a60b948f4-a1e2d9492bcd64dd, txn_id=27288862, node=51.89.232.179:8060, error message: [CANCELLED]Cancelled 116328739-W0228 16:58:34.781150 226848 vtablet_sink.cpp:635] cancel node channel VNodeChannel[11247281-23127439], load_id=732f7e3a60b948f4-a1e2d9492bcd64dd, txn_id=27288862, node=51.89.219.234:8060, error message: [CANCELLED]Cancelled 116328964:W0228 16:58:34.782094 226848 stream_load_executor.cpp:107] fragment execute failed, query_id=732f7e3a60b948f4-a1e2d9492bcd64dd, err_msg=[CANCELLED]Cancelled, id=732f7e3a60b948f4-a1e2d9492bcd64dd, job_id=24258401, txn_id=27288862, label=xxxxxx_data_load_123-24258401-732f7e3a60b948f4-a1e2d9492bcd64dd-27288862, elapse(s)=41 ``` I am not sure what exactly is the issue here? ### What You Expected? Routine load should consume messages as normal. ### How to Reproduce? _No response_ ### Anything Else? _No response_ ### Are you willing to submit PR? - [ ] 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) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org For additional commands, e-mail: commits-h...@doris.apache.org
