Morefarther commented on issue #49815:
URL: https://github.com/apache/doris/issues/49815#issuecomment-2826798561
try replace `max_retries` param with `retry_count ` param.
源码用的是retry_count参数，可能是官方文档笔误。1.0版本的可以试一下。
the code is:
`if response_json["Status"] == "Success"
@total_bytes.addAndGet(documents.size)
@total_rows.addAndGet(event_num)
break
else
@logger.warn("FAILED doris stream load response:\n#{response}")
if @retry_count >= 0 && req_count > @retry_count
@logger.warn("DROP this batch after failed #{req_count}
times.")
if @save_on_failure
@logger.warn("Try save to disk.Disk file path :
#{save_dir}/#{table}_#{save_file}")
save_to_disk(documents)
end
break
end
# sleep and then retry
sleep_for = sleep_for * 2
sleep_for = sleep_for <= 60 ? sleep_for : 60
sleep_rand = (sleep_for / 2) + (rand(0..sleep_for) / 2)
@logger.warn("Will do retry #{req_count} after sleep
#{sleep_rand} secs.")
sleep(sleep_rand)
end`
--
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]
