This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
from 7146661fa62 [fix](union) Terminate union sink if sources finished
(#56153)
add 47d972b3786 [feat](load): directly report the first data quality error
in load response (#55666)
No new revisions were added by this update.
Summary of changes:
be/src/io/fs/multi_table_pipe.cpp | 3 +++
.../exec/group_commit_block_sink_operator.cpp | 3 ++-
be/src/pipeline/pipeline_fragment_context.cpp | 26 ++++++++++++++++++++++
be/src/pipeline/pipeline_fragment_context.h | 3 ++-
be/src/runtime/fragment_mgr.cpp | 3 +++
be/src/runtime/group_commit_mgr.cpp | 3 +++
be/src/runtime/query_context.cpp | 10 +++++++++
be/src/runtime/query_context.h | 4 ++++
be/src/runtime/runtime_state.cpp | 3 +++
be/src/runtime/runtime_state.h | 3 +++
be/src/runtime/stream_load/stream_load_context.cpp | 13 +++++++++++
be/src/runtime/stream_load/stream_load_context.h | 1 +
.../runtime/stream_load/stream_load_executor.cpp | 3 ++-
be/src/service/internal_service.cpp | 3 +++
.../main/java/org/apache/doris/common/Config.java | 6 +++++
.../doris/job/extensions/insert/InsertJob.java | 16 +++++++++++++
.../doris/job/extensions/insert/InsertTask.java | 6 ++++-
.../main/java/org/apache/doris/load/EtlStatus.java | 12 ++++++++++
.../org/apache/doris/load/StreamLoadRecord.java | 5 ++++-
.../org/apache/doris/load/StreamLoadRecordMgr.java | 8 ++++---
.../apache/doris/load/loadv2/BrokerLoadJob.java | 3 +++
.../load/loadv2/BrokerLoadingTaskAttachment.java | 8 ++++++-
.../apache/doris/load/loadv2/InsertLoadJob.java | 6 +++--
.../java/org/apache/doris/load/loadv2/LoadJob.java | 3 +++
.../apache/doris/load/loadv2/LoadLoadingTask.java | 1 +
.../org/apache/doris/load/loadv2/LoadManager.java | 6 ++---
.../trees/plans/commands/ShowLoadCommand.java | 4 +++-
.../insert/BaseExternalTableInsertExecutor.java | 6 +++++
.../plans/commands/insert/JdbcInsertExecutor.java | 6 +++++
.../insert/OlapGroupCommitInsertExecutor.java | 6 +++++
.../plans/commands/insert/OlapInsertExecutor.java | 9 +++++++-
.../apache/doris/planner/GroupCommitPlanner.java | 11 +++++++++
.../main/java/org/apache/doris/qe/Coordinator.java | 9 ++++++++
.../main/java/org/apache/doris/qe/LoadContext.java | 9 ++++++++
.../org/apache/doris/qe/NereidsCoordinator.java | 5 +++++
.../org/apache/doris/qe/runtime/LoadProcessor.java | 3 +++
.../doris/load/loadv2/InsertLoadJobTest.java | 2 +-
.../apache/doris/load/loadv2/LoadManagerTest.java | 8 +++----
gensrc/proto/internal_service.proto | 1 +
gensrc/thrift/BackendService.thrift | 1 +
gensrc/thrift/FrontendService.thrift | 2 ++
.../org/apache/doris/regression/suite/Suite.groovy | 5 ++++-
.../manual-partitioning.md.groovy | 3 ++-
.../suites/insert_p0/test_insert_docs_demo.groovy | 2 +-
.../test_insert_partition_fail_url.groovy | 4 ++--
.../insert_p0/test_insert_strict_fail_url.groovy | 4 ++--
.../load_p0/broker_load/test_etl_failed.groovy | 3 ++-
.../test_stream_load_with_filtered_rows.groovy | 3 ++-
48 files changed, 237 insertions(+), 30 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
