This is an automated email from the ASF dual-hosted git repository.
caiconghui pushed a change to branch fix_export_timeout_not_work
in repository https://gitbox.apache.org/repos/asf/doris.git
from 6057aeed326 [fix](export) fix timeout property not work for export job
add 0eea19403e2 [fix](stats) analyze specific column only if indicate
column in analyze stmt (#25660)
add 8a436d8eccc [FIX](collectiontype) fix shrink char column in map/struct
(#25725)
add 20fa1eff65c [enhancement](Nereids) Filter no data partition after
partition prune (#25456)
add 4bda1650e12 [docs & fix](stats) Fix tablesample init failed and some
outdated contents in docs (#25603)
add a919ef618dd [fix](planner) Fix `select table tablet` not effective
(#25378)
add e8f479882da [pipelineX](local exchange) Add local exchange operator
(#25846)
add 01d5901356c [fix](Nereids) cte should support nested name reuse
(#25858)
add 8a8ae44eee8 [Fix](regression)Fix statistics related regression test
(#25888)
add f31c1d858a2 [fix](merge-on-write) fix duplicate key in schema change
(#25705)
add 41094eb3c10 Merge branch 'master' into fix_export_timeout_not_work
No new revisions were added by this update.
Summary of changes:
be/src/olap/full_compaction.cpp | 3 +-
be/src/olap/rowset/segment_v2/segment_iterator.cpp | 40 ++-
be/src/olap/rowset/segment_v2/segment_iterator.h | 1 +
be/src/olap/rowset_builder.cpp | 16 +-
be/src/olap/schema_change.cpp | 13 +-
be/src/olap/storage_engine.cpp | 7 +
be/src/olap/tablet.cpp | 32 +-
be/src/olap/tablet.h | 2 +-
be/src/olap/tablet_meta.cpp | 5 -
be/src/olap/task/engine_clone_task.cpp | 10 +
be/src/olap/task/engine_publish_version_task.cpp | 32 +-
be/src/pipeline/exec/exchange_sink_operator.cpp | 10 +-
be/src/pipeline/pipeline_x/dependency.h | 44 +++
.../local_exchange_sink_operator.cpp | 87 ++++++
.../local_exchange/local_exchange_sink_operator.h | 102 +++++++
.../local_exchange_source_operator.cpp | 52 ++++
.../local_exchange_source_operator.h | 67 +++++
be/src/pipeline/pipeline_x/operator.cpp | 6 +
be/src/pipeline/pipeline_x/operator.h | 9 +-
.../pipeline_x/pipeline_x_fragment_context.cpp | 52 +++-
.../pipeline_x/pipeline_x_fragment_context.h | 4 +
be/src/pipeline/pipeline_x/pipeline_x_task.cpp | 14 +-
be/src/pipeline/pipeline_x/pipeline_x_task.h | 10 +-
be/src/runtime/runtime_state.h | 3 +
be/src/vec/columns/column.h | 2 +
be/src/vec/columns/column_map.cpp | 21 ++
be/src/vec/columns/column_map.h | 4 +-
be/src/vec/columns/column_nullable.h | 2 +
be/src/vec/columns/column_struct.cpp | 15 +
be/src/vec/columns/column_struct.h | 4 +
be/src/vec/runtime/partitioner.cpp | 56 +++-
be/src/vec/runtime/partitioner.h | 29 +-
be/src/vec/sink/vdata_stream_sender.cpp | 9 +-
be/src/vec/sink/vdata_stream_sender.h | 7 +
docs/en/docs/query-acceleration/statistics.md | 8 +-
docs/zh-CN/docs/query-acceleration/statistics.md | 8 +-
.../java/org/apache/doris/nereids/CTEContext.java | 10 +-
.../doris/nereids/jobs/executor/Rewriter.java | 2 +
.../org/apache/doris/nereids/rules/RuleType.java | 1 +
.../doris/nereids/rules/analysis/AnalyzeCTE.java | 23 +-
...sIntoJdbcScan.java => PruneEmptyPartition.java} | 23 +-
.../trees/plans/logical/LogicalOlapScan.java | 1 -
.../org/apache/doris/planner/OlapScanNode.java | 21 +-
.../java/org/apache/doris/qe/SessionVariable.java | 9 +
.../apache/doris/statistics/AnalysisManager.java | 4 +-
.../apache/doris/statistics/BaseAnalysisTask.java | 2 +-
.../org/apache/doris/analysis/SelectStmtTest.java | 137 ++++++++-
.../rules/rewrite/PruneOlapScanTabletTest.java | 2 -
gensrc/thrift/PaloInternalService.thrift | 4 +-
.../test_nestedtypes_csv_insert_into_with_s3.out | 2 +-
.../test_nestedtypes_json_insert_into_with_s3.out | 6 +-
regression-test/data/export/test_struct_export.out | Bin 469 -> 442 bytes
.../hive/test_hive_statistic_timeout.out | 7 -
.../data/insert_p0/test_struct_insert.out | Bin 444 -> 417 bytes
.../data/load_p0/stream_load/map_char_test.csv | 4 +
.../data/load_p0/stream_load/test_stream_load.out | 6 +
.../data/nereids_p0/cte/test_cte_name_reuse.out | 10 +
.../aggregate/aggregate_group_by_metric_type.out | Bin 170 -> 154 bytes
.../struct_functions/test_struct_functions.out | Bin 1379 -> 1294 bytes
.../hive/test_hive_analyze_db.groovy | 308 +++++++++----------
.../hive/test_hive_partition_statistic.groovy | 2 +-
.../hive/test_hive_statistic.groovy | 334 ++++++++++-----------
.../hive/test_hive_statistic_cache.groovy | 288 +++++++++---------
.../hive/test_hive_statistic_clean.groovy | 115 +++----
.../hive/test_hive_statistic_timeout.groovy | 20 +-
.../load_p0/stream_load/test_stream_load.groovy | 40 ++-
.../test_cte_name_reuse.groovy} | 49 +--
.../suites/statistics/analyze_stats.groovy | 14 +
68 files changed, 1504 insertions(+), 726 deletions(-)
create mode 100644
be/src/pipeline/pipeline_x/local_exchange/local_exchange_sink_operator.cpp
create mode 100644
be/src/pipeline/pipeline_x/local_exchange/local_exchange_sink_operator.h
create mode 100644
be/src/pipeline/pipeline_x/local_exchange/local_exchange_source_operator.cpp
create mode 100644
be/src/pipeline/pipeline_x/local_exchange/local_exchange_source_operator.h
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/{PushConjunctsIntoJdbcScan.java
=> PruneEmptyPartition.java} (60%)
delete mode 100644
regression-test/data/external_table_p2/hive/test_hive_statistic_timeout.out
create mode 100644 regression-test/data/load_p0/stream_load/map_char_test.csv
create mode 100644 regression-test/data/nereids_p0/cte/test_cte_name_reuse.out
copy regression-test/suites/nereids_p0/{test_forbid_unknown_col_stats.groovy
=> cte/test_cte_name_reuse.groovy} (54%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
