HHoflittlefish777 opened a new pull request, #36450:
URL: https://github.com/apache/doris/pull/36450
## Proposed changes
before
```
ErrorReason{code=errCode = 105, msg='be 10002 abort task, task id:
d846f3d3-7c9e-44a7-bee0-3eff8cd11c6f job id: 11310 with reason:
[INTERNAL_ERROR]Offset out of range,
0# doris::Status doris::Status::Error<6,
true>(std::basic_string_view<char, std::char_traits<char> >) at
/mnt/disk1/laihui/doris/be/src/common/status.h:422
1# doris::Status
doris::Status::InternalError<true>(std::basic_string_view<char,
std::char_traits<char> >) at /mnt/disk1/laihui/doris/be/src/common/status.h:468
2#
doris::KafkaDataConsumer::group_consume(doris::BlockingQueue<RdKafka::Message*>*,
long) at
/mnt/disk1/laihui/doris/be/src/runtime/routine_load/data_consumer.cpp:226
3#
doris::KafkaDataConsumerGroup::actual_consume(std::shared_ptr<doris::DataConsumer>,
doris::BlockingQueue<RdKafka::Message*>*, long, std::function<void
(doris::Status const&)>) at
/mnt/disk1/laihui/doris/be/src/runtime/routine_load/data_consumer_group.cpp:200
4# void std::__invoke_impl<void, void
(doris::KafkaDataConsumerGroup::*&)(std::shared_ptr<doris::DataConsumer>,
doris::BlockingQueue<RdKafka::Message*>*, long, std::function<void
(doris::Status const&)>), doris::KafkaDataConsumerGroup*&,
std::shared_ptr<doris::DataConsumer>&,
doris::BlockingQueue<RdKafka::Message*>*&, long&,
doris::KafkaDataConsumerGroup::start_all(std::shared_ptr<doris::StreamLoadContext>,
std::shared_ptr<doris::io::KafkaConsumerPipe>)::$_0&>(std::__invoke_memfun_deref,
void (doris::KafkaDataConsumerGroup::*&)(std::shared_ptr<doris::DataConsumer>,
doris::BlockingQueue<RdKafka::Message*>*, long, std::function<void
(doris::Status const&)>), doris::KafkaDataConsumerGroup*&,
std::shared_ptr<doris::DataConsumer>&,
doris::BlockingQueue<RdKafka::Message*>*&, long&,
doris::KafkaDataConsumerGroup::start_all(std::shared_ptr<doris::StreamLoadContext>,
std::shared_ptr<doris::io::KafkaConsumerPipe>)::$_0&) at
/mnt/disk1/laihui/build/ldb_toolchain/bin/../lib/gcc/x86_6
4-linux-gnu/11/../../../../include/c++/11/bits/invoke.h:74
...
```
now
```
ErrorReason{code=errCode = 105, msg='be 10002 abort task, task id:
3ba0c0f4-d13c-4dfa-90ce-3df922fd9340 job id: 11310 with reason:
[INTERNAL_ERROR]Offset out of range, consume partition 0, consume offset 100,
the offset used by job does not exist in kafka, please check the offset, using
the Alter ROUTINE LOAD command to modify it, and resume the job'}
```
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
