This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a change to branch branch-4.0-preview
in repository https://gitbox.apache.org/repos/asf/doris.git
from 127b8776f48 [fix](merge-cloud) fix inconsistency between cloud mode
and local mode for 2PC (#33917)
new b7468d81078 [fix](variable) modify @@auto_commit column type to BIGINT
in Nereids. #33887
new df55669e17f [fix](stream-load) fix stream load and http stream metric
error #33899
new f6ef9492655 [Fix](Csv-Reader)Fix the issue of BE core dump caused by
improper configuration of column_seperator and line_delimiter. (#33693)
new 951daa62149 [fix](cloud) Fix missing time unit ms when recycle expired
txn (#33915)
new 8688f24b227 [enhancement](cloud)avoid transaction too large when
dropping partition (#33700)
new 14cdfcb27fb [perf](routine-load) reduce waiting in task scheduler to
accelerate consume (#33756)
new fa537134e74 [fix](pipeline_x) The execution loop of a task should be
broken if the task is cancelled (#33938)
new 65d8959f360 [feature](cloud) Add priority network support for
meta-service registry (#33931)
new a818f11b4a2 [chore](HDFS) Print file size when hdfs file writer failed
(#33918)
new a7266f2c0a4 [bug](fix) heap use after free when json parse failed
(#33955)
new 799077eec55 (cloud-merge) Fix the cast failed when RollupJobV2 convert
to CloudRollupJobV2 (#33847)
new cb5de24b548 n [fix](HDFS) Correctly set hdfs cache allocator's offset
(#33960)
new f1111fd0306 [case](Cloud) Add chaos storage vault cases (#33730)
new 476832abb39 [opt](inverted index) topn opt reads only limit number of
records (#33163)
new 351714a143d [fix](schema change) fix schema change check does not
calculate reader merged rows (#33825)
The 15 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
be/src/cloud/injection_point_action.cpp | 56 ++++-
be/src/common/config.cpp | 2 +
be/src/common/config.h | 2 +
be/src/http/action/http_stream.cpp | 3 +-
be/src/http/action/stream_load.cpp | 3 +-
be/src/io/fs/hdfs_file_reader.cpp | 5 +
be/src/io/fs/hdfs_file_writer.cpp | 43 +++-
be/src/olap/iterators.h | 1 +
be/src/olap/rowset/beta_rowset_reader.cpp | 4 +
be/src/olap/rowset/beta_rowset_reader.h | 6 +
be/src/olap/rowset/rowset_reader.h | 4 +
be/src/olap/rowset/rowset_reader_context.h | 1 +
be/src/olap/rowset/segment_v2/segment_iterator.cpp | 20 ++
be/src/olap/rowset/segment_v2/segment_iterator.h | 2 +
be/src/olap/schema_change.h | 12 +-
be/src/pipeline/pipeline_x/pipeline_x_task.cpp | 8 +
be/src/vec/exec/format/csv/csv_reader.cpp | 8 +-
be/src/vec/exec/format/json/new_json_reader.cpp | 2 +-
be/src/vec/olap/vcollect_iterator.cpp | 1 +
cloud/src/common/CMakeLists.txt | 1 +
cloud/src/common/config.h | 8 +
cloud/src/common/network_util.cpp | 238 +++++++++++++++++++++
cloud/src/common/network_util.h | 34 +++
cloud/src/meta-service/meta_server.cpp | 3 +-
cloud/src/meta-service/meta_service_partition.cpp | 47 +---
cloud/src/meta-service/meta_service_resource.cpp | 10 +-
cloud/src/recycler/recycler.cpp | 3 +-
cloud/test/CMakeLists.txt | 4 +
cloud/test/meta_service_test.cpp | 30 +--
cloud/test/network_util_test.cpp | 49 +++++
.../org/apache/doris/alter/AlterJobV2Factory.java | 3 +-
.../org/apache/doris/alter/CloudRollupJobV2.java | 32 +--
.../apache/doris/alter/CloudSchemaChangeJobV2.java | 36 ++--
.../cloud/datasource/CloudInternalCatalog.java | 12 +-
.../load/routineload/RoutineLoadTaskScheduler.java | 7 -
.../main/java/org/apache/doris/qe/VariableMgr.java | 12 ++
.../java/org/apache/doris/qe/VariableMgrTest.java | 19 ++
gensrc/proto/cloud.proto | 1 +
.../stream_load/load_json_parse_failed/test | 4 +
.../data/load_p0/stream_load/special_seperator.csv | 2 +
.../stream_load/test_csv_special_seperator.out | 5 +
.../inject_hdfs_load_error.groovy | 116 ++++++++++
.../inject_hdfs_select_error.groovy | 104 +++++++++
.../load_json_parse_failed.groovy | 49 +++++
.../stream_load/test_csv_special_seperator.groovy | 69 ++++++
45 files changed, 937 insertions(+), 144 deletions(-)
create mode 100644 cloud/src/common/network_util.cpp
create mode 100644 cloud/src/common/network_util.h
create mode 100644 cloud/test/network_util_test.cpp
create mode 100644
regression-test/data/load_p0/stream_load/load_json_parse_failed/test
create mode 100644
regression-test/data/load_p0/stream_load/special_seperator.csv
create mode 100644
regression-test/data/load_p0/stream_load/test_csv_special_seperator.out
create mode 100755
regression-test/suites/inject_hdfs_vault_p0/inject_hdfs_load_error.groovy
create mode 100755
regression-test/suites/inject_hdfs_vault_p0/inject_hdfs_select_error.groovy
create mode 100644
regression-test/suites/load_p0/stream_load/load_json_parse_failed/load_json_parse_failed.groovy
create mode 100644
regression-test/suites/load_p0/stream_load/test_csv_special_seperator.groovy
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
