This is an automated email from the ASF dual-hosted git repository.
liaoxin pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
from 46cbe76a130 [fix](job) fix routine load task scheduler block for one
job can not find any BE (#52654)
add a598835d8b8 [fix](sink) fix sink operator tolerate failed replica
number incorrect (#52560)
No new revisions were added by this update.
Summary of changes:
be/src/exec/tablet_info.cpp | 6 +
be/src/exec/tablet_info.h | 2 +
be/src/runtime/load_channel.cpp | 3 +
be/src/vec/sink/writer/vtablet_writer.cpp | 31 +++++-
be/src/vec/sink/writer/vtablet_writer.h | 7 ++
be/src/vec/sink/writer/vtablet_writer_v2.cpp | 29 ++++-
be/src/vec/sink/writer/vtablet_writer_v2.h | 10 +-
be/test/vec/sink/vtablet_writer_v2_test.cpp | 96 +++++++++-------
.../java/org/apache/doris/catalog/OlapTable.java | 6 +-
.../org/apache/doris/planner/OlapTableSink.java | 15 ++-
gensrc/thrift/Descriptors.thrift | 2 +
.../apache/doris/regression/util/DebugPoint.groovy | 18 +++
.../load_p0/stream_load/test_sink_tolerate.groovy | 121 +++++++++++++++++++++
13 files changed, 294 insertions(+), 52 deletions(-)
create mode 100644
regression-test/suites/load_p0/stream_load/test_sink_tolerate.groovy
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
