This is an automated email from the ASF dual-hosted git repository.
w41ter pushed a change to branch auto-pick-42459-branch-3.0
in repository https://gitbox.apache.org/repos/asf/doris.git
omit 2d888e661f7 [improve](backup) Reduce backup/restore job log size by
compress (#42459)
add 60deaf68f99 [fix](Nerieds) fix FoldConstantRuleOnFE too slow when
CaseWhen clause nesting multiple layers (#42897) (#42910)
add ca35ea385fa [Test](bloom filter) add retry query for bloom filter test
case #42937 (#42974)
add 3082951c917 [fix](metrics) Fix doris compaction deltas total #42071
(#42960)
add e9e0c38f60a [fix](jdbc catalog) fix be crash when create jdbc catalog
without driver jar #42948 (#42971)
add 86bb03435e1 [fix](task) Abort creating replica task if sending RPC
failed #42276 (#42961)
add 0c27eda872c [improvement](statistics)Add log for estimating hive table
row count logic. (#42921) (#42980)
add d60268d30c8 [fix](cloud) fix job status is empty when label reused in
cloud mode (#42878)
add b4ac202787c [fix](regression) fix txn_insert (#42885) (#42957)
add 48bb6ad0c5e [improve](restore) Log create replica task progress #42350
(#42964)
add 7769c68d682 [branch-3.0](pick) Pick #41789 #42482 #41210 #42460
(#42914)
add 4da628deb77 [improve](task) Support splitting agent batch tasks
automatically #42703 (#42989)
add 01c19648979 [Test](count on index) add statistics check for unique
table #42982 (#43021)
add 78f31d72468 [3.0][opt](Catalog) Remove unnecessary conjuncts handling
on External Scan (#43018)
add f4f82299ee2 [fix](cloud) Fix incorrect DCHECK in txn lazy commit
`convert_tmp_rowset` (#42903) (#42988)
add 340334659c1 [improvement](statistics)Improve statisitcs insert into
audit log. (#42983) (#43053)
add 2abe20b020c [branch-3.0](pick) pick #42857 #42898 #42909 #42992 #43002
(#43039)
add d27c1bb0472 [enhance](auth) Optimize the authentication logic of
Ranger Doris (#41207) (#41840)
add 8034ab187d4 [enhance](mtmv)Mtmv support audit log (#41499) (#41841)
add 959bd31183d [fix](mtmv) cannot refresh mtmv when base table recreating
(#41762) (#42340)
add db0986e512b [fix](case)Fix multiple case tables with the same name
causing case failure (#42203) (#43041)
add 594865c34f5 [improvement](statistics)External table getRowCount return
-1 when row count is not available or row count is 0. (#43009) (#43081)
add 757b0ea23c5 [fix](regression-test) fix test_hive_serde_prop #42886
(#43099)
add e46149b6fd4 [cherry-pick](branch-3.0) Pick "[Feature](schema change)
Support add column bitmap with default value bitmap_empty (#42331)" (#42701)
add 502d9e5bdcd [fix](exit) stop storage engine in exec_env before exit
(#42015) (#43141)
add d3c02efe38c [feature](statistics)Support get row count for pg and sql
server. (#42674) (#43150)
add 48ea74b050a [enhancement](Nereids) boost characterLiteralTypeCoercion
(#42941) (#43094)
add 14a1edc6ec9 [fix](spill) disable fuzzy spill for now (#42892) (#42894)
add 84e5de52505 [test](p0) fix load stream leak in injection cases
(#42681) (#43160)
add 4d8e5f3c8dd [Opt](Variant) merge schema in sync_rowsets to prevents
from CPU overhead each time describe table(#42856) (#43062)
add 8120c598d35 [enhancement](cloud) refine block file cache evict policy
(#42451) (#43201)
add 9bae30a383a [fix](regression) fix flaky partial update cases (#42072)
(#43202)
add e679fbe97d3 [improve](routine load) adjust default values to make
routine load more convenient to use (#42968)
add d5c8b9a7cfa [test](move memtable) fix move memtable injection case
fail (#42639) (#42671)
add 874f58e4369 [fix](regression-test) Revome "UNIQUE KEY (k1)" case for
test_dynamic_partition_mod_distribution_key (#41002) (#43181)
add 3a50bde11b6 [fix](compaction) Filter out all not running tablets if
cumu compaction for shadow tablets is disabled (#42245) (#43209)
add d9f270a0ed3 [cloud](Variant) limit column size in MetaService and
support handle rowset schema in backend side(#41482) (#43093)
add 6429b0d1b02 [fix](auditlog) set isQuery to true when query is short
circuited(#42647) (#43067)
add 9e327e877bc [test](ES Catalog)Add mapping _routing test case (#42074)
(#42284)
add 21daa9b6d93 [fix](index compaction)Skip writing terms with a doc
frequency of 0(#43113) (#43116)
add b42b874948d [improve](backup) Reduce backup/restore job log size by
compress (#42459)
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 (2d888e661f7)
\
N -- N -- N refs/heads/auto-pick-42459-branch-3.0 (b42b874948d)
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:
be/src/cloud/cloud_meta_mgr.cpp | 8 +-
be/src/cloud/cloud_storage_engine.cpp | 6 +-
be/src/cloud/cloud_tablet.cpp | 45 +-
be/src/cloud/cloud_tablet.h | 6 +
be/src/cloud/pb_convert.cpp | 55 +-
be/src/cloud/pb_convert.h | 12 +-
be/src/clucene | 2 +-
be/src/common/config.cpp | 6 +-
be/src/common/config.h | 1 +
be/src/io/cache/block_file_cache.cpp | 260 ++-
be/src/io/cache/block_file_cache.h | 27 +-
be/src/io/cache/file_cache_common.cpp | 5 +
be/src/io/cache/file_cache_common.h | 16 +-
be/src/olap/olap_common.h | 26 +-
be/src/olap/rowset/rowset_reader_context.h | 2 -
be/src/olap/rowset/segment_v2/segment_iterator.cpp | 75 +-
be/src/olap/rowset/segment_v2/segment_iterator.h | 4 +-
.../rowset/segment_v2/vertical_segment_writer.cpp | 4 +-
be/src/pipeline/dependency.h | 8 +-
be/src/pipeline/exec/aggregation_sink_operator.cpp | 9 +-
be/src/pipeline/exec/aggregation_sink_operator.h | 11 +-
.../pipeline/exec/aggregation_source_operator.cpp | 51 +-
be/src/pipeline/exec/aggregation_source_operator.h | 11 +-
be/src/pipeline/exec/analytic_sink_operator.cpp | 61 +-
be/src/pipeline/exec/analytic_sink_operator.h | 7 +-
be/src/pipeline/exec/analytic_source_operator.cpp | 39 +-
be/src/pipeline/exec/analytic_source_operator.h | 8 +-
be/src/pipeline/exec/assert_num_rows_operator.cpp | 1 +
be/src/pipeline/exec/cache_source_operator.cpp | 20 +-
be/src/pipeline/exec/datagen_operator.cpp | 24 +-
be/src/pipeline/exec/datagen_operator.h | 2 +
.../distinct_streaming_aggregation_operator.cpp | 5 +-
.../exec/distinct_streaming_aggregation_operator.h | 7 +-
be/src/pipeline/exec/es_scan_operator.cpp | 8 +-
be/src/pipeline/exec/es_scan_operator.h | 3 +-
be/src/pipeline/exec/exchange_sink_operator.cpp | 75 +-
be/src/pipeline/exec/exchange_sink_operator.h | 23 +-
be/src/pipeline/exec/exchange_source_operator.cpp | 23 +-
be/src/pipeline/exec/exchange_source_operator.h | 5 +-
.../exec/group_commit_block_sink_operator.cpp | 52 +-
.../exec/group_commit_block_sink_operator.h | 7 +-
.../pipeline/exec/group_commit_scan_operator.cpp | 1 +
be/src/pipeline/exec/hashjoin_build_sink.cpp | 17 +-
be/src/pipeline/exec/hashjoin_build_sink.h | 13 +-
be/src/pipeline/exec/hashjoin_probe_operator.cpp | 7 +-
be/src/pipeline/exec/hashjoin_probe_operator.h | 7 +-
be/src/pipeline/exec/jdbc_table_sink_operator.cpp | 1 +
.../pipeline/exec/join/process_hash_table_probe.h | 7 +-
.../exec/join/process_hash_table_probe_impl.h | 18 +-
be/src/pipeline/exec/join_build_sink_operator.cpp | 10 +-
be/src/pipeline/exec/join_build_sink_operator.h | 2 -
be/src/pipeline/exec/join_probe_operator.cpp | 4 +-
be/src/pipeline/exec/join_probe_operator.h | 2 +-
.../pipeline/exec/memory_scratch_sink_operator.cpp | 24 +-
.../pipeline/exec/memory_scratch_sink_operator.h | 3 +
.../exec/multi_cast_data_stream_source.cpp | 13 +-
.../pipeline/exec/multi_cast_data_stream_source.h | 3 +
.../exec/nested_loop_join_build_operator.cpp | 1 -
.../exec/nested_loop_join_build_operator.h | 4 +-
.../exec/nested_loop_join_probe_operator.cpp | 41 +-
.../exec/nested_loop_join_probe_operator.h | 80 +-
be/src/pipeline/exec/olap_scan_operator.cpp | 80 +-
be/src/pipeline/exec/olap_scan_operator.h | 24 +-
be/src/pipeline/exec/operator.cpp | 19 +-
be/src/pipeline/exec/operator.h | 31 +-
.../exec/partitioned_aggregation_sink_operator.h | 3 -
.../partitioned_aggregation_source_operator.cpp | 4 +
.../exec/partitioned_aggregation_source_operator.h | 2 +
.../exec/partitioned_hash_join_probe_operator.h | 3 -
.../exec/partitioned_hash_join_sink_operator.h | 3 -
be/src/pipeline/exec/repeat_operator.cpp | 75 +-
be/src/pipeline/exec/repeat_operator.h | 5 +
be/src/pipeline/exec/result_file_sink_operator.cpp | 6 -
be/src/pipeline/exec/result_file_sink_operator.h | 14 -
be/src/pipeline/exec/result_sink_operator.cpp | 14 +-
be/src/pipeline/exec/result_sink_operator.h | 7 +-
be/src/pipeline/exec/scan_operator.cpp | 9 +-
be/src/pipeline/exec/scan_operator.h | 8 +-
be/src/pipeline/exec/set_probe_sink_operator.cpp | 11 +-
be/src/pipeline/exec/set_probe_sink_operator.h | 5 +-
be/src/pipeline/exec/set_sink_operator.cpp | 8 +-
be/src/pipeline/exec/set_sink_operator.h | 7 +-
be/src/pipeline/exec/set_source_operator.cpp | 37 +-
be/src/pipeline/exec/set_source_operator.h | 3 +
be/src/pipeline/exec/sort_sink_operator.cpp | 12 +-
be/src/pipeline/exec/sort_sink_operator.h | 6 +-
be/src/pipeline/exec/sort_source_operator.cpp | 4 +-
.../exec/streaming_aggregation_operator.cpp | 28 +-
.../pipeline/exec/streaming_aggregation_operator.h | 18 +-
be/src/pipeline/exec/table_function_operator.cpp | 22 +-
be/src/pipeline/exec/table_function_operator.h | 8 +
be/src/pipeline/exec/union_sink_operator.cpp | 1 +
be/src/pipeline/exec/union_sink_operator.h | 2 +
be/src/pipeline/exec/union_source_operator.h | 4 +-
.../local_exchange_sink_operator.cpp | 6 +-
.../local_exchange/local_exchange_sink_operator.h | 2 +-
.../local_exchange_source_operator.h | 3 -
be/src/pipeline/local_exchange/local_exchanger.cpp | 2 +-
be/src/pipeline/local_exchange/local_exchanger.h | 11 +-
be/src/pipeline/pipeline.cpp | 44 +-
be/src/pipeline/pipeline.h | 46 +-
be/src/pipeline/pipeline_fragment_context.cpp | 322 ++--
be/src/pipeline/pipeline_fragment_context.h | 38 +-
be/src/runtime/exec_env_init.cpp | 2 +-
be/src/runtime/stream_load/stream_load_context.h | 7 +-
be/src/service/internal_service.cpp | 5 +-
be/src/util/arrow/row_batch.cpp | 17 +-
be/src/util/arrow/row_batch.h | 7 +-
be/src/util/doris_metrics.cpp | 4 +-
.../vec/aggregate_functions/aggregate_function.h | 43 +-
.../aggregate_functions/aggregate_function_avg.h | 22 +-
.../aggregate_function_bitmap.h | 24 +-
.../aggregate_function_bitmap_agg.h | 22 +-
.../aggregate_functions/aggregate_function_count.h | 44 +-
.../aggregate_function_count_by_enum.h | 4 +-
.../aggregate_function_histogram.h | 4 +-
.../aggregate_function_hll_union_agg.h | 2 +-
.../aggregate_function_java_udaf.h | 6 +-
.../aggregate_functions/aggregate_function_map.h | 18 +-
.../aggregate_function_min_max.h | 158 +-
.../aggregate_function_min_max_by.h | 44 +-
.../aggregate_function_percentile.h | 2 +-
.../aggregate_function_reader_first_last.h | 4 +-
.../aggregate_functions/aggregate_function_rpc.h | 2 +-
.../aggregate_functions/aggregate_function_sort.h | 6 +-
.../aggregate_functions/aggregate_function_sum.h | 22 +-
.../aggregate_functions/aggregate_function_uniq.h | 8 +-
.../aggregate_function_uniq_distribute_key.h | 26 +-
.../aggregate_function_window.h | 23 +-
be/src/vec/exec/scan/new_es_scanner.cpp | 11 +-
be/src/vec/exec/scan/new_olap_scanner.cpp | 191 +-
be/src/vec/exec/scan/new_olap_scanner.h | 2 -
be/src/vec/exec/scan/scanner_context.cpp | 38 +-
be/src/vec/exec/scan/scanner_context.h | 23 +-
be/src/vec/exec/scan/scanner_scheduler.cpp | 9 +-
be/src/vec/exec/scan/vfile_scanner.cpp | 6 +-
be/src/vec/exec/scan/vfile_scanner.h | 3 -
be/src/vec/exec/scan/vscanner.cpp | 6 +-
be/src/vec/exec/vjdbc_connector.cpp | 3 +
be/src/vec/olap/vertical_block_reader.cpp | 1 -
be/src/vec/sink/vdata_stream_sender.cpp | 17 +-
be/src/vec/sink/vdata_stream_sender.h | 4 +-
be/test/io/cache/block_file_cache_test.cpp | 1911 ++++++++++++++++----
.../index_compaction_with_deleted_term.cpp | 671 +++++++
.../serde/data_type_serde_arrow_test.cpp | 654 -------
cloud/src/common/config.h | 6 +-
cloud/src/meta-service/meta_service.cpp | 4 +-
cloud/src/meta-service/meta_service_schema.cpp | 25 +-
cloud/src/meta-service/meta_service_schema.h | 6 +-
cloud/src/meta-service/meta_service_txn.cpp | 1 +
cloud/src/meta-service/txn_lazy_committer.cpp | 3 +-
.../elasticsearch/scripts/es_init.sh | 14 +-
.../elasticsearch/scripts/index/es6_test3.json | 27 +
.../elasticsearch/scripts/index/es7_test3.json | 3 +
.../docker-compose/mysql/init/04-insert.sql | 1 +
.../docker-compose/postgresql/init/04-insert.sql | 1 +
.../docker-compose/sqlserver/init/04-insert.sql | 1 +
.../main/java/org/apache/doris/common/Config.java | 7 +
fe/fe-core/src/main/cup/sql_parser.cup | 7 +
.../org/apache/doris/alter/SchemaChangeJobV2.java | 2 +-
.../java/org/apache/doris/analysis/ColumnDef.java | 3 +-
.../java/org/apache/doris/backup/BackupJob.java | 9 +-
.../java/org/apache/doris/backup/RestoreJob.java | 43 +-
.../main/java/org/apache/doris/catalog/Column.java | 5 +
.../java/org/apache/doris/catalog/OlapTable.java | 10 +-
.../main/java/org/apache/doris/catalog/Table.java | 2 +-
.../java/org/apache/doris/catalog/TableIf.java | 2 +
.../authorizer/ranger/RangerAccessController.java | 7 +
.../ranger/cache/CatalogCacheAccessController.java | 91 -
.../authorizer/ranger/cache/DatamaskCacheKey.java | 89 -
.../authorizer/ranger/cache/RangerCache.java | 107 --
.../authorizer/ranger/cache/RowFilterCacheKey.java | 82 -
.../authorizer/ranger/doris/DorisAccessType.java | 79 +-
.../authorizer/ranger/doris/DorisObjectType.java | 2 +-
.../doris/RangerCacheDorisAccessController.java | 44 -
.../ranger/doris/RangerDorisAccessController.java | 177 +-
.../ranger/doris/RangerDorisResource.java | 6 +-
.../hive/RangerCacheHiveAccessController.java | 47 -
.../hive/RangerHiveAccessControllerFactory.java | 2 +-
.../transaction/CloudGlobalTransactionMgr.java | 3 +-
.../doris/common/LabelAlreadyUsedException.java | 21 +
.../apache/doris/common/MarkedCountDownLatch.java | 14 +
.../doris/datasource/ExternalRowCountCache.java | 7 +-
.../org/apache/doris/datasource/ExternalTable.java | 4 +-
.../apache/doris/datasource/FileQueryScanNode.java | 11 +-
.../doris/datasource/es/source/EsScanNode.java | 2 +
.../doris/datasource/hive/HMSExternalTable.java | 56 +-
.../doris/datasource/hive/source/HiveScanNode.java | 39 +-
.../datasource/iceberg/IcebergExternalTable.java | 3 +-
.../doris/datasource/iceberg/IcebergUtils.java | 8 +-
.../doris/datasource/jdbc/JdbcExternalTable.java | 96 +-
.../maxcompute/source/MaxComputeScanNode.java | 14 +-
.../datasource/paimon/PaimonExternalTable.java | 8 +-
.../datasource/paimon/source/PaimonScanNode.java | 4 +
.../source/TrinoConnectorScanNode.java | 4 +-
.../apache/doris/job/extensions/mtmv/MTMVTask.java | 43 +-
.../doris/load/routineload/RoutineLoadJob.java | 2 +-
.../java/org/apache/doris/mtmv/MTMVPlanUtil.java | 1 +
.../doris/mtmv/MTMVRefreshPartitionSnapshot.java | 34 +
.../mysql/privilege/AccessControllerManager.java | 10 +-
.../glue/translator/PhysicalPlanTranslator.java | 2 -
.../doris/nereids/jobs/executor/Rewriter.java | 8 +-
.../doris/nereids/rules/analysis/BindRelation.java | 4 +-
.../rules/expression/rules/FoldConstantRule.java | 2 +-
.../expression/rules/FoldConstantRuleOnFE.java | 3 -
.../LogicalEsScanToPhysicalEsScan.java | 3 +-
.../LogicalFileScanToPhysicalFileScan.java | 1 -
.../LogicalHudiScanToPhysicalHudiScan.java | 1 -
.../LogicalJdbcScanToPhysicalJdbcScan.java | 3 +-
.../LogicalOdbcScanToPhysicalOdbcScan.java | 3 +-
.../nereids/rules/rewrite/AdjustNullable.java | 12 -
.../rules/rewrite/PruneFileScanPartition.java | 12 +-
.../rules/rewrite/PushConjunctsIntoJdbcScan.java | 39 -
.../rules/rewrite/PushConjunctsIntoOdbcScan.java | 39 -
.../trees/copier/LogicalPlanDeepCopier.java | 17 -
.../expressions/functions/SearchSignature.java | 9 +-
.../trees/expressions/literal/DateLiteral.java | 73 +-
.../trees/expressions/literal/DateTimeLiteral.java | 75 +-
.../expressions/literal/DateTimeV2Literal.java | 2 +-
.../expressions/literal/DecimalV3Literal.java | 13 +-
.../nereids/trees/expressions/literal/Result.java | 66 +
.../expressions/literal/format/AndChecker.java} | 38 +-
.../expressions/literal/format/AtLeastChecker.java | 49 +
.../expressions/literal/format/CharChecker.java} | 20 +-
.../expressions/literal/format/CheckResult.java | 49 +
.../literal/format/CustomCharChecker.java} | 23 +-
.../literal/format/DateTimeChecker.java | 137 ++
.../expressions/literal/format/DebugChecker.java} | 22 +-
.../expressions/literal/format/DigitChecker.java} | 38 +-
.../expressions/literal/format/FloatChecker.java | 55 +
.../expressions/literal/format/FormatChecker.java | 170 ++
.../literal/format/IntegerChecker.java} | 32 +-
.../expressions/literal/format/LetterChecker.java} | 38 +-
.../expressions/literal/format/OptionChecker.java} | 20 +-
.../expressions/literal/format/OrChecker.java | 55 +
.../expressions/literal/format/StringChecker.java} | 28 +-
.../expressions/literal/format/StringInspect.java | 64 +
.../nereids/trees/plans/logical/LogicalEsScan.java | 26 +-
.../plans/logical/LogicalExternalRelation.java | 68 -
.../trees/plans/logical/LogicalFileScan.java | 32 +-
.../trees/plans/logical/LogicalHudiScan.java | 24 +-
.../trees/plans/logical/LogicalJdbcScan.java | 24 +-
.../trees/plans/logical/LogicalOdbcScan.java | 24 +-
.../trees/plans/physical/PhysicalEsScan.java | 23 +-
.../trees/plans/physical/PhysicalFileScan.java | 29 +-
.../trees/plans/physical/PhysicalHudiScan.java | 17 +-
.../trees/plans/physical/PhysicalJdbcScan.java | 25 +-
.../trees/plans/physical/PhysicalOdbcScan.java | 26 +-
.../trees/plans/visitor/RelationVisitor.java | 13 +-
.../apache/doris/nereids/types/DecimalV3Type.java | 25 +-
.../doris/nereids/util/TypeCoercionUtils.java | 54 +-
.../org/apache/doris/planner/AggregationNode.java | 6 +
.../org/apache/doris/planner/AnalyticEvalNode.java | 11 +
.../apache/doris/planner/AssertNumRowsNode.java | 5 +
.../org/apache/doris/planner/DataPartition.java | 4 +
.../org/apache/doris/planner/EmptySetNode.java | 1 -
.../org/apache/doris/planner/ExchangeNode.java | 29 +
.../org/apache/doris/planner/JoinNodeBase.java | 1 -
.../apache/doris/planner/NestedLoopJoinNode.java | 15 +
.../org/apache/doris/planner/PlanFragment.java | 20 +
.../java/org/apache/doris/planner/PlanNode.java | 14 +
.../java/org/apache/doris/planner/RepeatNode.java | 6 +
.../java/org/apache/doris/planner/ScanNode.java | 7 +
.../java/org/apache/doris/planner/SelectNode.java | 6 +
.../java/org/apache/doris/planner/SortNode.java | 6 +
.../java/org/apache/doris/planner/UnionNode.java | 7 +
.../main/java/org/apache/doris/qe/Coordinator.java | 37 +-
.../java/org/apache/doris/qe/SessionVariable.java | 7 +-
.../java/org/apache/doris/qe/StmtExecutor.java | 1 +
.../org/apache/doris/statistics/AnalysisJob.java | 2 +-
.../doris/statistics/StatisticsAutoCollector.java | 2 +-
.../doris/statistics/util/StatisticsUtil.java | 15 +-
.../java/org/apache/doris/task/AgentBatchTask.java | 48 +-
.../main/java/org/apache/doris/task/AgentTask.java | 4 +
.../org/apache/doris/task/CreateReplicaTask.java | 17 +
fe/fe-core/src/main/jflex/sql_scanner.flex | 1 +
.../datasource/ExternalRowCountCacheTest.java | 32 +-
.../apache/doris/external/hms/HmsCatalogTest.java | 30 +
.../doris/load/routineload/RoutineLoadJobTest.java | 2 +-
.../nereids/rules/rewrite/AdjustNullableTest.java | 74 -
.../trees/expressions/literal/DateLiteralTest.java | 16 +-
.../expressions/literal/DateTimeLiteralTest.java | 496 ++---
.../expressions/literal/FloatLiteralTest.java | 80 +
.../expressions/literal/IntegerLiteralTest.java | 64 +
.../org/apache/doris/qe/HmsQueryCacheTest.java | 6 +
gensrc/proto/cloud.proto | 12 +-
gensrc/thrift/PlanNodes.thrift | 1 +
.../test_alter_add_column_default_value.out | 14 +
.../data/external_table_p0/es/test_es_query.out | 12 +
.../hive/test_hive_serde_prop.out | 15 +-
.../data/mtmv_p0/test_recreate_table_mtmv.out | 13 +
.../test_alter_add_column_default_value.groovy | 66 +
...est_bloom_filter_hit_with_renamed_column.groovy | 3 +-
.../external_table_p0/es/test_es_query.groovy | 2 +
.../jdbc/test_jdbc_row_count.groovy | 107 ++
.../jdbc/test_mysql_jdbc_statistics.groovy | 11 -
.../test_writer_v2_fault_injection.groovy | 10 +-
.../suites/insert_p0/transaction/txn_insert.groovy | 2 +-
.../inverted_index_p0/test_count_on_index.groovy | 48 +-
.../stream_load/test_stream_load_job_status.groovy | 90 +
.../suites/mtmv_p0/test_recreate_table_mtmv.groovy | 91 +
.../insert_into_table/complex_insert.groovy | 6 +-
.../suites/nereids_p0/union/test_union.groovy | 12 +-
.../distribute/local_shuffle.groovy | 14 +-
.../slow_fold_constant_case_when.groovy | 824 +++++++++
...t_dynamic_partition_mod_distribution_key.groovy | 92 +-
..._partition_mod_distribution_key_restart.groovy} | 11 +-
.../suites/query_p0/union/test_union.groovy | 12 +-
.../partial_update/test_mix_partial_update.groovy | 11 +
.../partial_update/test_mix_partial_update.groovy | 11 +
.../test_partial_update_merge_type.groovy | 7 +
.../suites/variant_p0/column_size_limit.groovy | 33 +-
312 files changed, 7643 insertions(+), 4204 deletions(-)
create mode 100644
be/test/olap/rowset/segment_v2/inverted_index/compaction/index_compaction_with_deleted_term.cpp
delete mode 100644 be/test/vec/data_types/serde/data_type_serde_arrow_test.cpp
create mode 100644
docker/thirdparties/docker-compose/elasticsearch/scripts/index/es6_test3.json
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/catalog/authorizer/ranger/cache/CatalogCacheAccessController.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/catalog/authorizer/ranger/cache/DatamaskCacheKey.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/catalog/authorizer/ranger/cache/RangerCache.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/catalog/authorizer/ranger/cache/RowFilterCacheKey.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/catalog/authorizer/ranger/doris/RangerCacheDorisAccessController.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/catalog/authorizer/ranger/hive/RangerCacheHiveAccessController.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/PushConjunctsIntoJdbcScan.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/PushConjunctsIntoOdbcScan.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/literal/Result.java
rename
fe/fe-core/src/main/java/org/apache/doris/nereids/{rules/rewrite/PushConjunctsIntoEsScan.java
=> trees/expressions/literal/format/AndChecker.java} (51%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/literal/format/AtLeastChecker.java
copy
fe/fe-core/src/main/java/org/apache/doris/{catalog/authorizer/ranger/hive/RangerHiveAccessControllerFactory.java
=> nereids/trees/expressions/literal/format/CharChecker.java} (65%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/literal/format/CheckResult.java
copy
fe/fe-core/src/main/java/org/apache/doris/{catalog/authorizer/ranger/hive/RangerHiveAccessControllerFactory.java
=> nereids/trees/expressions/literal/format/CustomCharChecker.java} (56%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/literal/format/DateTimeChecker.java
copy
fe/fe-core/src/main/java/org/apache/doris/{catalog/authorizer/ranger/hive/RangerHiveAccessControllerFactory.java
=> nereids/trees/expressions/literal/format/DebugChecker.java} (53%)
copy
fe/fe-core/src/main/java/org/apache/doris/{catalog/authorizer/ranger/cache/RangerCacheInvalidateListener.java
=> nereids/trees/expressions/literal/format/DigitChecker.java} (50%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/literal/format/FloatChecker.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/literal/format/FormatChecker.java
copy
fe/fe-core/src/main/java/org/apache/doris/{catalog/authorizer/ranger/cache/RangerCacheInvalidateListener.java
=> nereids/trees/expressions/literal/format/IntegerChecker.java} (52%)
rename
fe/fe-core/src/main/java/org/apache/doris/{catalog/authorizer/ranger/cache/RangerCacheInvalidateListener.java
=> nereids/trees/expressions/literal/format/LetterChecker.java} (50%)
copy
fe/fe-core/src/main/java/org/apache/doris/{catalog/authorizer/ranger/hive/RangerHiveAccessControllerFactory.java
=> nereids/trees/expressions/literal/format/OptionChecker.java} (62%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/literal/format/OrChecker.java
copy
fe/fe-core/src/main/java/org/apache/doris/{catalog/authorizer/ranger/hive/RangerHiveAccessControllerFactory.java
=> nereids/trees/expressions/literal/format/StringChecker.java} (54%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/literal/format/StringInspect.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/logical/LogicalExternalRelation.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/rules/rewrite/AdjustNullableTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/expressions/literal/FloatLiteralTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/expressions/literal/IntegerLiteralTest.java
create mode 100644
regression-test/data/alter_p0/test_alter_add_column_default_value.out
create mode 100644 regression-test/data/mtmv_p0/test_recreate_table_mtmv.out
create mode 100644
regression-test/suites/alter_p0/test_alter_add_column_default_value.groovy
create mode 100644
regression-test/suites/external_table_p0/jdbc/test_jdbc_row_count.groovy
create mode 100644
regression-test/suites/load_p0/stream_load/test_stream_load_job_status.groovy
create mode 100644
regression-test/suites/mtmv_p0/test_recreate_table_mtmv.groovy
create mode 100644
regression-test/suites/nereids_syntax_p0/slow_fold_constant_case_when.groovy
copy
regression-test/suites/partition_p0/dynamic_partition/{test_dynamic_partition_mod_distribution_key.groovy
=> test_dynamic_partition_mod_distribution_key_restart.groovy} (88%)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
