This is an automated email from the ASF dual-hosted git repository.
Gabriel39 pushed a change to branch refactor_0702
in repository https://gitbox.apache.org/repos/asf/doris.git
discard a0dc6bfb472 [fix](be) Forward DefaultFunction pruning hooks
discard 3ef904b179e [fix](be) Fix parquet scan page index UTs
discard 38eb879229b [test](be) Fix parquet empty selection profile test
discard 1076dec661a [test](be) Fix parquet page index planner test
discard 00c69bda7db [fix](be) Implement parquet test expr execution stubs
discard b56fae99927 [fix](be) Restore parquet merge read options
discard a095f80036f [fix](be) Avoid parquet scheduler option call
discard a803d113613 [fix](be) Fix BE compile errors
discard e3dd7a3d44e [refactor](be) Use VExpr for file scanner pruning
add 88de0eecc6c [test](case) add refresh table before select sql (#65156)
add c5a8e0d1c38 [refine](column) separate mutable subcolumn mutation from
read-only traversal (#65087)
add 3f0200c51d1 [fix](regression) check partition minmax only (#65180)
add f631250a110 [fix](fe) Accept spaced TIMESTAMPTZ offsets in range
partition bounds (#64795)
add 6dbf100ce40 [test](regression) skip Arrow-incompatible complex outputs
(#65182)
add 1fa3ca3e317 [chore](be) Refine tablet reader context and generic
reader handling (#62970)
add 07bcd31ae7c [improvement](fe) Prune partition keys from partition topn
sort (#63379)
add 7bfda3179b6 [fix](be) Fix null query crash in inverted index
predicates (#65138)
add 3f57f8e8341 [test](regression) Update HDFS parquet group4 output
(#65194)
add e2bfaa807f0 [fix](regression) Batch export_p0 generated VALUES inserts
(#65208)
add 49e888e2450 [fix](streaming-job) Support delete sign in CDC stream TVF
(#65146)
add 5c7110b978c [fix](glue) cache credentials provider in
ConfigurationAWSCredentialsProvider (#65165)
add f401ccb56de [refine](pipeline) Add exchange source debug details
(#65167)
add fcffadcb67c [fix](orc) decode timestamp through serde (#64854)
add 0b6a20f458e [feat](dynamic table) support table stream part 4:
support snapshot read (#64776)
add 9561ad9e8c9 [fix](fe) Parse MaxCompute partition specs by name (#64937)
add 1866967e048 [fix](regression) Adjust large TTL cache regression case
(#64789)
add 122f3b0d8f1 [fix](orc)fix hive-orc reader read columns base in column
index by default rather than column name. (#65085)
add 0c8ee958394 [fix](fe) Fix show data all result row width (#65215)
add 6c6b72924b2 [fix](maxcompute)Fix MaxCompute IN predicate pushdown
polarity. (#65083)
add 9012d3bd6f3 [fix](regression) handle E-2010 compaction success wait
(#65209)
add 61920b70576 [fix](regression) wait for adaptive scan profile (#64923)
add cad35a6d73f [codex] Add CODEOWNERS for airborne12-owned paths (#65239)
add e9cf1cc6b95 [refactor](be) Use VExpr for file scanner pruning
add 91a55a51a27 [fix](be) Fix BE compile errors
add e4cf1e96103 [fix](be) Avoid parquet scheduler option call
add 9cb8e5db0bc [fix](be) Restore parquet merge read options
add a0abe86fa99 [fix](be) Implement parquet test expr execution stubs
add af1a72c3b57 [test](be) Fix parquet page index planner test
add 5e9f6b7cff7 [test](be) Fix parquet empty selection profile test
add 3d7a6201e75 [fix](be) Fix parquet scan page index UTs
add eb6ffed8f85 [fix](be) Forward DefaultFunction pruning hooks
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (a0dc6bfb472)
\
N -- N -- N refs/heads/refactor_0702 (eb6ffed8f85)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.github/CODEOWNERS | 18 +-
be/src/cloud/pb_convert.cpp | 12 +
be/src/core/block/block.cpp | 10 +-
be/src/core/column/column.cpp | 37 +-
be/src/core/column/column.h | 33 +-
be/src/core/column/column_array.h | 17 +-
be/src/core/column/column_const.h | 6 +-
be/src/core/column/column_map.h | 20 +-
be/src/core/column/column_nullable.h | 15 +-
be/src/core/column/column_struct.cpp | 10 +-
be/src/core/column/column_struct.h | 3 +-
be/src/core/column/column_variant.cpp | 31 +-
be/src/core/column/column_variant.h | 3 +-
be/src/exec/operator/exchange_source_operator.cpp | 51 +-
be/src/exec/operator/olap_scan_operator.cpp | 21 +-
be/src/exec/operator/olap_scan_operator.h | 4 +
be/src/exec/scan/olap_scanner.cpp | 38 +-
be/src/exec/scan/olap_scanner.h | 3 +-
be/src/exprs/function/function_multi_match.cpp | 17 +-
be/src/format/generic_reader.h | 4 -
be/src/format/orc/vorc_reader.cpp | 13 +-
.../storage/iterator/binlog_block_reader_utils.h | 8 +-
be/src/storage/rowset/beta_rowset_reader.cpp | 6 +-
be/src/storage/rowset/rowset_reader_context.h | 3 +
be/src/storage/schema.cpp | 1 +
be/src/storage/schema.h | 5 +
be/src/storage/segment/column_reader.cpp | 23 +
be/src/storage/segment/column_reader.h | 107 ++-
be/src/storage/segment/column_reader_cache.cpp | 4 +-
be/src/storage/segment/column_reader_cache.h | 6 +-
be/src/storage/segment/segment.cpp | 40 +-
be/src/storage/segment/segment.h | 7 +-
be/src/storage/tablet/tablet_meta.cpp | 3 +
be/src/storage/tablet/tablet_reader.cpp | 1 +
be/src/storage/tablet/tablet_reader.h | 3 +
be/src/storage/tablet/tablet_schema.cpp | 7 +
be/src/storage/tablet/tablet_schema.h | 2 +
be/src/storage/utils.h | 1 +
.../core/column/column_mutate_subcolumns_test.cpp | 304 +++++++++
be/test/format/orc/orc_reader_fill_data_test.cpp | 36 +
.../iterator/block_reader_min_delta_test.cpp | 15 +-
.../segment/constant_column_iterator_test.cpp | 192 ++++++
.../segment/segment_iterator_expr_zonemap_test.cpp | 131 +++-
be/test/storage/tablet/tablet_schema_helper.cpp | 14 +
be/test/storage/tablet/tablet_schema_helper.h | 2 +
be/test/storage/tablet/tablet_schema_test.cpp | 34 +
.../main/java/org/apache/doris/catalog/Column.java | 11 +-
.../ConfigurationAWSCredentialsProvider.java | 45 +-
.../apache/doris/alter/SchemaChangeHandler.java | 3 +
.../org/apache/doris/analysis/TableScanParams.java | 31 +-
.../java/org/apache/doris/binlog/BinlogUtils.java | 6 +
.../org/apache/doris/catalog/OlapTableWrapper.java | 38 +-
.../org/apache/doris/catalog/PartitionKey.java | 20 +-
.../doris/catalog/RowBinlogTableWrapper.java | 37 +-
.../doris/catalog/stream/OlapTableStream.java | 41 +-
.../catalog/stream/OlapTableStreamUpdate.java | 27 +-
.../catalog/stream/OlapTableStreamWrapper.java | 65 +-
.../doris/clone/DynamicPartitionScheduler.java | 45 +-
.../cloud/alter/CloudSchemaChangeHandler.java | 9 +-
.../cloud/datasource/CloudInternalCatalog.java | 5 +
.../doris/common/profile/SummaryProfile.java | 25 +
.../apache/doris/common/util/PropertyAnalyzer.java | 32 +-
.../apache/doris/datasource/InternalCatalog.java | 1 +
.../maxcompute/MaxComputeExternalTable.java | 35 +-
.../maxcompute/source/MaxComputeScanNode.java | 4 +-
.../doris/mtmv/MTMVPartitionExprDateTrunc.java | 21 +-
.../org/apache/doris/nereids/NereidsPlanner.java | 30 +-
.../glue/translator/PhysicalPlanTranslator.java | 37 +-
.../properties/ChildOutputPropertyDeriver.java | 9 +-
.../org/apache/doris/nereids/rules/RuleSet.java | 2 -
.../doris/nereids/rules/analysis/BindRelation.java | 249 ++++++-
.../LogicalOlapScanToPhysicalOlapScan.java | 1 -
...ogicalPartitionTopNToPhysicalPartitionTopN.java | 39 +-
.../nereids/rules/rewrite/EliminateOrderByKey.java | 31 +-
.../rewrite/NormalizeOlapTableStreamScan.java | 411 ++++++++----
.../nereids/rules/rewrite/PruneOlapScanTablet.java | 2 +-
.../nereids/rules/rewrite/SetPreAggStatus.java | 5 -
.../expressions/literal/StringLikeLiteral.java | 12 +-
.../expressions/literal/TimestampTzLiteral.java | 162 +++--
.../trees/plans/commands/ShowDataCommand.java | 4 +-
.../plans/commands/info/ColumnDefinition.java | 12 +
.../trees/plans/commands/info/CreateTableInfo.java | 15 +
.../commands/info/ModifyTablePropertiesOp.java | 2 +
.../commands/insert/InsertIntoTableCommand.java | 47 +-
.../insert/StreamConsumptionInfoExtractor.java | 93 +++
.../trees/plans/logical/LogicalOlapScan.java | 49 +-
.../plans/logical/LogicalOlapTableStreamScan.java | 176 +++--
.../trees/plans/physical/PhysicalOlapScan.java | 24 +-
.../plans/physical/PhysicalPartitionTopN.java | 21 +
.../doris/nereids/util/TypeCoercionUtils.java | 28 +-
.../org/apache/doris/planner/OlapScanNode.java | 55 +-
.../main/java/org/apache/doris/qe/Coordinator.java | 101 ---
.../org/apache/doris/qe/NereidsCoordinator.java | 2 -
.../java/org/apache/doris/qe/SessionVariable.java | 8 +-
.../doris/qe/TimeBasedChangeVisibleWaiter.java | 178 +++++
.../CdcStreamTableValuedFunction.java | 12 +-
.../org/apache/doris/task/CreateReplicaTask.java | 5 +
.../doris/analysis/PartitionExprUtilTest.java | 44 ++
.../apache/doris/analysis/TableScanParamsTest.java | 95 +++
.../apache/doris/catalog/CreateTableLikeTest.java | 157 +++++
.../doris/catalog/DynamicPartitionTableTest.java | 299 +++++++++
.../org/apache/doris/catalog/PartitionKeyTest.java | 158 +++++
.../catalog/stream/OlapTableStreamUpdateTest.java | 22 +-
.../stream/TableStreamManagerCleanupTest.java | 7 -
.../apache/doris/common/PropertyAnalyzerTest.java | 38 ++
.../maxcompute/MaxComputeExternalTableTest.java | 50 ++
...TMVRelatedPartitionDescRollUpGeneratorTest.java | 72 ++
.../translator/PhysicalPlanTranslatorTest.java | 33 +
.../rules/implementation/ImplementationTest.java | 23 +
.../rules/rewrite/EliminateOrderByKeyTest.java | 57 +-
.../GeneratePartitionTopnFromWindowTest.java | 51 ++
.../expressions/literal/StringLikeLiteralTest.java | 41 ++
.../literal/TimestampTzLiteralTest.java | 122 ++++
.../trees/plans/ExplainTableStreamPlanTest.java | 123 +++-
.../trees/plans/commands/ShowDataCommandTest.java | 53 ++
.../InsertIntoTableCommandTableStreamTest.java | 74 +--
.../doris/qe/TimeBasedChangeVisibleWaiterTest.java | 140 ++++
.../apache/doris/qe/WaitForChangeVisibleTest.java | 204 ------
.../CdcStreamTableValuedFunctionTest.java | 101 +++
.../TableStreamOffsetTransactionTest.java | 20 +-
gensrc/proto/olap_file.proto | 6 +
gensrc/thrift/AgentService.thrift | 1 +
...est_timestamptz_partition_boundary_timezone.out | 26 +
.../tvf/test_hdfs_parquet_group4.out | 115 ++--
.../test_max_compute_in_predicate_pushdown.out | 24 +
.../test_multi_match_null_query.out | 28 +
..._streaming_job_cdc_stream_mysql_delete_sign.out | 21 +
...reaming_job_cdc_stream_postgres_delete_sign.out | 21 +
.../test_aggregate_all_functions.out | 9 +
.../shape_check/tpcds_sf100/rf_prune/query44.out | 12 +-
.../data/shape_check/tpcds_sf100/shape/query44.out | 12 +-
.../tpcds_sf1000/bs_downgrade_shape/query44.out | 12 +-
.../shape_check/tpcds_sf1000/shape/query44.out | 12 +-
.../tpcds_sf1000_nopkfk/shape/query44.out | 12 +-
.../test_olap_table_stream_history_consumption.out | 9 -
.../test_olap_table_stream_history_query.out | 197 ------
...olap_table_stream_mixed_history_incremental.out | 8 +
.../test_table_stream_query_comprehensive.out | 38 ++
.../data/time_travel_p0/test_time_travel_dup.out | 14 +
.../data/time_travel_p0/test_time_travel_mow.out | 10 +
.../test_time_travel_mow_complex.out | 12 +
.../doris/regression/action/ProfileAction.groovy | 107 ++-
regression-test/plugins/plugin_compaction.groovy | 7 +-
.../cloud_p0/cache/ttl/alter_ttl_max_int64.groovy | 41 +-
..._timestamptz_partition_boundary_timezone.groovy | 257 +++++++
.../outfile/native/test_outfile_native.groovy | 17 +-
.../suites/export_p0/test_outfile.groovy | 14 +-
.../suites/export_p0/test_outfile_expr.groovy | 14 +-
.../hive/test_different_column_orders.groovy | 1 +
.../hive/test_hive_orc_timestamp_timezone.groovy | 132 ++++
.../test_max_compute_in_predicate_pushdown.groovy | 102 +++
.../hive_on_hms_and_dlf.groovy | 6 +
.../test_multi_match_null_query.groovy | 76 +++
...reaming_job_cdc_stream_mysql_delete_sign.groovy | 157 +++++
...ming_job_cdc_stream_postgres_delete_sign.groovy | 159 +++++
.../suites/query_p0/cast/test_cast.groovy | 15 +-
.../explain/test_global_partition_topn_plan.groovy | 55 ++
.../test_aggregate_all_functions.groovy | 9 +-
.../query_p0/stats/partition_key_minmax.groovy | 39 +-
...ptive_pipeline_task_serial_read_on_limit.groovy | 55 +-
.../query_profile/s3_load_profile_test.groovy | 140 ++--
.../suites/query_profile/scanner_profile.groovy | 137 ++--
.../suites/show_p0/test_show_data_all_db.groovy | 41 ++
.../table_stream_p0/test_min_delta_stream.groovy | 17 +-
...st_olap_table_stream_history_consumption.groovy | 4 -
.../test_olap_table_stream_history_query.groovy | 117 ++--
...p_table_stream_mixed_history_incremental.groovy | 71 ++
.../test_olap_table_stream_reset.groovy | 293 ++++++++
.../test_olap_table_stream_snapshot.groovy | 276 ++++++++
.../test_olap_table_stream_snapshot_count.groovy | 88 +++
.../test_table_stream_query_comprehensive.groovy | 735 +++++++++++++++++++++
.../time_travel_p0/test_time_travel_dup.groovy | 83 +++
.../time_travel_p0/test_time_travel_mow.groovy | 90 +++
.../test_time_travel_mow_complex.groovy | 70 ++
174 files changed, 7884 insertions(+), 1768 deletions(-)
create mode 100644 be/test/core/column/column_mutate_subcolumns_test.cpp
create mode 100644 be/test/storage/segment/constant_column_iterator_test.cpp
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/insert/StreamConsumptionInfoExtractor.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/qe/TimeBasedChangeVisibleWaiter.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/analysis/TableScanParamsTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/maxcompute/MaxComputeExternalTableTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/qe/TimeBasedChangeVisibleWaiterTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/qe/WaitForChangeVisibleTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/tablefunction/CdcStreamTableValuedFunctionTest.java
create mode 100644
regression-test/data/datatype_p0/timestamptz/test_timestamptz_partition_boundary_timezone.out
create mode 100644
regression-test/data/external_table_p2/maxcompute/test_max_compute_in_predicate_pushdown.out
create mode 100644
regression-test/data/inverted_index_p0/test_multi_match_null_query.out
create mode 100644
regression-test/data/job_p0/streaming_job/cdc/tvf/test_streaming_job_cdc_stream_mysql_delete_sign.out
create mode 100644
regression-test/data/job_p0/streaming_job/cdc/tvf/test_streaming_job_cdc_stream_postgres_delete_sign.out
delete mode 100644
regression-test/data/table_stream_p0/test_olap_table_stream_history_query.out
create mode 100644
regression-test/data/table_stream_p0/test_olap_table_stream_mixed_history_incremental.out
create mode 100644
regression-test/data/table_stream_p0/test_table_stream_query_comprehensive.out
create mode 100644 regression-test/data/time_travel_p0/test_time_travel_dup.out
create mode 100644 regression-test/data/time_travel_p0/test_time_travel_mow.out
create mode 100644
regression-test/data/time_travel_p0/test_time_travel_mow_complex.out
create mode 100644
regression-test/suites/datatype_p0/timestamptz/test_timestamptz_partition_boundary_timezone.groovy
create mode 100644
regression-test/suites/external_table_p0/hive/test_hive_orc_timestamp_timezone.groovy
create mode 100644
regression-test/suites/external_table_p2/maxcompute/test_max_compute_in_predicate_pushdown.groovy
create mode 100644
regression-test/suites/inverted_index_p0/test_multi_match_null_query.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/tvf/test_streaming_job_cdc_stream_mysql_delete_sign.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/tvf/test_streaming_job_cdc_stream_postgres_delete_sign.groovy
create mode 100644 regression-test/suites/show_p0/test_show_data_all_db.groovy
create mode 100644
regression-test/suites/table_stream_p0/test_olap_table_stream_mixed_history_incremental.groovy
create mode 100644
regression-test/suites/table_stream_p0/test_olap_table_stream_reset.groovy
create mode 100644
regression-test/suites/table_stream_p0/test_olap_table_stream_snapshot.groovy
create mode 100644
regression-test/suites/table_stream_p0/test_olap_table_stream_snapshot_count.groovy
create mode 100644
regression-test/suites/table_stream_p0/test_table_stream_query_comprehensive.groovy
create mode 100644
regression-test/suites/time_travel_p0/test_time_travel_dup.groovy
create mode 100644
regression-test/suites/time_travel_p0/test_time_travel_mow.groovy
create mode 100644
regression-test/suites/time_travel_p0/test_time_travel_mow_complex.groovy
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
