This is an automated email from the ASF dual-hosted git repository.
lijibing pushed a change to branch high-priority-column
in repository https://gitbox.apache.org/repos/asf/doris.git
discard 6e27cc8bcb9 Use future to block auto analyze before job finish.
(#33083)
omit 7bd1809ae1f fix visible column (#33023)
add cc50d8cd807 [fix](merge-cloud) fix adjustment compaction thread num
core dump bug (#32962)
add 8391807af1b [improvement](inverted index)Avoid parsing ignore_above in
add_values and return error status when rowid_conversion is failed. (#32890)
add a7d236a6235 [Fix](hive-writer) Fix correct num when hive writing data
to an unpartitioned table if size large than `hive_sink_max_file_size`. (#32959)
add 7ea31a97ac9 [fix](insert)fix hive external return msgs and exception
and pass all columns to BE (#32824)
add e434a59cb05 [chore](cloud) remove unused include in meta service
(#32934)
add 9e68e91cfd7 [fix](test) replace 'null' to null for date/datetime
column (#32972)
add 6d66196123c [fix](variant)group name optimization (#32598)
add 39d695c05c7 [opt](fqdn) Add DNS Cache for FE and BE (#32869)
add 50815b1eb7c [opt](iceberg) no need to check the name format of
iceberg's database (#32977)
add a5cad88cc2f [bugfx](Cloud) Add refresh hdfs vault logic && check
whether latest fs is nullptr (#32981)
add 473a3261e13 [Fix](trino-connector) fix hive split info of
trino-connector catalog (#32615)
add 7453b804686 [chore](ci) adjust ckb expect result (#32856)
add 55e02a0508c [chore](ci) fix ci check (#32992)
add 03585010bc9 [shuffle](fix) Do not use copy assignment for TUniqueId
(#32969)
add 639449043ac [enhance](auth) add show privileges stmt(#32918)
add f3813669ac9 [scan](status) Finish execution if scanner failed (#32966)
add 793a3222b06 [Bug](Variant) use lower case name for variant's root,
since backend treat parent column as lower case (#32999)
add d25bfe44ec8 [opt](memory) Optimize mem tracker accuracy (#32039)
add f0dd4507368 [enhance](auth)when assigning permissions, the current
user must have corresponding permissions (#32825)
add 4edb6cff27b [opt](log) refactor the log dir config (#32933)
add bf3fd9e1221 [build](audit-loader) remove the build script of audit
loader in build.sh (#32956)
add f19ba762c88 [fix](jni) avoid coredump if failed to get jni env (#32950)
add 630846b9740 [Improvement](execution) Use single phase execution commit
if only 1 BE is used (#32937)
add 90036ee1ace [Fix](Variant) forbit table with variant type doing
segment compaction temporarily (#33001)
add 3a5ee41d860 [fix](invert index) Fix the issue of high memory usage.
(#31739)
add 86e99f9cf7d [chore](session_variable) change
parallel_scan_min_rows_per_scanner' default value to 16384 (#32939)
add 367836ab999 [fix](nereids)column name should be case insensitive when
selecting mv (#33002)
add d1095a2d92c [fix](nereids)partition prune should consider <=> operator
(#32965)
add 8f449585c0b [enhancement](nereids)add some date functions for constant
fold (#32772)
add 360d5b2fe80 [fix](nereids) null-safe-eq runtime filter denies outer
join #32927
add 6624c94ce2a [Performance](sink) opt mysql result writer (#31816)
add 7bcd240346c [fix](nereids)BE cannot find min-max runtime filter on
nested loop join node (#32886)
add e954ba141a4 [fix](inverted index) Clear the index cache corresponding
to the table after deleting the table. (#32921)
add d4f933585be [regression-test](Variant) add order by to make test
stable (#33014)
add 3ff63ed9741 [bug](function) fix milliseconds_diff function return
wrong result (#32897)
add 87806462cb7 [improvement](spill) spill trigger improvement (#32641)
add 97123cf7b81 [fix](mtmv)partition limit #32978
add a57bde80828 1 Add running query num/waiting query num (#33024)
add 3f883ce971b [Improvement](materialized-view) The materialized view can
not involved auto increment column (#32885)
add 347b04877ac [improve](txn insert) txn insert support update stmt
(#33034)
add aeeb1cbf8d8 [fix](planner) remove and retain input slot for aggregate
slot which is not materialized (#33033)
add 232e8189da9 [Fix](segment compaction)
_check_and_set_is_doing_segcompaction should be the last condition (#33041)
add cb6287e2acb [fix](path-gc) Fix pending rowset guard check failure when
ordered data compaction failed (#33026)
add 5c934e7bb39 [regression](insert)add hive DDL and CTAS regression case
(#32924)
add 37ea92d5de5 [statistic](cloud) Add session variable
force_sample_analyze, default false (#32117)
add af1cddbaca9 [fix](cloud) mysqlload works with cluster and refactor
code (#32716)
add 54a6030d8a4 [fix](memory) Fix CloudDeltaWriter init attach task in
thread context (#33048)
add f64a83402c8 [Cloud](array)temp ban cloud case for array index (#33017)
add 52ed33f7a11 [pipelineX](local exchange) Fix potential timeout problem
(#33022)
add 9d265aa8fbb [partitionsort](fix) Fix DCHECK failure (#33035)
add 2a4ae8f5787 [fix](memory) Fix CloudEngineCalcDeleteBitmapTask handle()
attach task in thread context (#33057)
add 786f238bff1 [Bug](runtime-filter) fix unknown filter on nested loop
join sink (#32832)
add dd7034122a1 [BugFix] Fix rename error because the new dir exists
(#33042)
add 122b64deb05 [fix](agg) incorrect result with having conjuncts and
limit (#33040)
add 3dcc97c473b [bug](cloud) Use cached visible version when Fe replay
(#33054)
add 2a7876bf85e [fix](planner) retain groupingSlotIds as materialized for
aggregate (#33060)
add fdd4036eb63 [Fix](pipelinex) Fix `MaxScannerThreadNum` calculation
error in file scan operator when turn on pipelinex. (#33037)
add a8214dbdbb9 [fix](Cloud) Carry properties with storage vault (#33065)
add 2b94cd1060d [fix] (vectorization) regexp all_pass string (#32515)
add 6df957d2ed0 [feature](insert)add hive insert plan ut and remove
redundant fields (#33051)
add 5a37b92ea54 [fix](case) ignore case disable light_schema_change in
cloud mode (#33067)
add efc7b630d30 [fix](memory) Fix MemTableWriter flush_async attach task
in thread context (#33071)
add c19c2462056 [bugfix](iceberg)Convert the datetime type in the
predicate according to the target column (#32923)
add 9ceceb4d78f [fix](memory) Fix erase invalid MemTrackerLimiter from
tracker pool (#33074)
add 14e44244716 [fix](typo) typo fix for 'delete bimap' changing to
'delete bitmap' (#32341)
add 10f6eb048ae [opt](rowcount) refresh external table's rowcount async
(#32997)
add 23240ef0df2 [fix](pipelineX) fix error open in scan #33069
add 2f8775dd2cd [Enhancement](hive-writer) Write only regular fields to
file in the hive-writer. (#33000)
add cdcc6f3041d [Fix](Hive-Metastore) fix that if JDBC reads the NULL
value, it will cause NPE (#32831)
add e834d809992 [fix](memory) Fix erase MemTrackerLimiter from tracker
pool (#33078)
add b42285f2de1 [featrue](expr) support common subexpression elimination
be part (#32673)
new 1e857658d8a fix visible column (#33023)
new 97dcfcf01c7 Use future to block auto analyze before job finish.
(#33083)
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 (6e27cc8bcb9)
\
N -- N -- N refs/heads/high-priority-column (97dcfcf01c7)
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.
The 2 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:
.github/workflows/comment-to-trigger-teamcity.yml | 7 +-
be/src/agent/task_worker_pool.cpp | 6 +-
be/src/cloud/cloud_delete_task.cpp | 3 +
be/src/cloud/cloud_delta_writer.cpp | 6 +-
be/src/cloud/cloud_delta_writer.h | 3 +
.../cloud/cloud_engine_calc_delete_bitmap_task.cpp | 15 +-
.../cloud/cloud_engine_calc_delete_bitmap_task.h | 2 +
be/src/cloud/cloud_rowset_builder.cpp | 3 +
be/src/cloud/cloud_schema_change_job.cpp | 3 +
be/src/cloud/cloud_storage_engine.cpp | 31 +-
be/src/cloud/cloud_storage_engine.h | 2 +-
be/src/cloud/cloud_tablet.cpp | 2 +-
be/src/common/config.cpp | 11 +-
be/src/common/config.h | 14 +-
be/src/common/daemon.cpp | 13 +
be/src/common/daemon.h | 1 +
be/src/common/logconfig.cpp | 7 +-
be/src/exec/exec_node.cpp | 83 +-
be/src/exec/exec_node.h | 24 +
be/src/exec/rowid_fetcher.cpp | 2 +
be/src/http/action/stream_load.cpp | 4 +
be/src/http/default_path_handlers.cpp | 7 +-
be/src/http/http_common.h | 1 +
be/src/io/cache/fs_file_cache_storage.cpp | 1 +
be/src/io/fs/local_file_system.cpp | 2 -
be/src/io/fs/s3_file_bufferpool.cpp | 7 +-
be/src/io/fs/stream_load_pipe.cpp | 1 -
be/src/olap/calc_delete_bitmap_executor.cpp | 2 +
be/src/olap/calc_delete_bitmap_executor.h | 1 +
be/src/olap/compaction.cpp | 20 +-
be/src/olap/compaction.h | 1 +
be/src/olap/delta_writer.h | 1 -
be/src/olap/delta_writer_v2.cpp | 1 -
be/src/olap/memtable.cpp | 19 +-
be/src/olap/memtable.h | 9 +-
be/src/olap/memtable_flush_executor.cpp | 1 +
be/src/olap/memtable_memory_limiter.cpp | 10 +-
be/src/olap/memtable_memory_limiter.h | 8 +-
be/src/olap/memtable_writer.cpp | 6 +-
be/src/olap/memtable_writer.h | 1 +
be/src/olap/olap_server.cpp | 3 +
be/src/olap/page_cache.cpp | 2 +-
be/src/olap/page_cache.h | 21 +-
be/src/olap/push_handler.cpp | 6 +-
be/src/olap/rowset/beta_rowset_writer.cpp | 1 +
be/src/olap/rowset/pending_rowset_helper.cpp | 31 +
be/src/olap/rowset/pending_rowset_helper.h | 22 +-
be/src/olap/rowset/segcompaction.cpp | 2 +-
.../inverted_index/query/phrase_edge_query.cpp | 94 +-
.../inverted_index/query/phrase_edge_query.h | 5 +
.../rowset/segment_v2/inverted_index_cache.cpp | 10 +-
.../rowset/segment_v2/inverted_index_writer.cpp | 14 +-
be/src/olap/rowset/segment_v2/page_io.cpp | 6 +-
be/src/olap/rowset/segment_v2/segment.cpp | 10 +-
be/src/olap/rowset/segment_v2/segment.h | 8 +-
be/src/olap/storage_engine.cpp | 6 +-
be/src/olap/storage_engine.h | 19 -
be/src/olap/tablet_manager.cpp | 26 +-
be/src/olap/tablet_meta.h | 8 +-
be/src/olap/tablet_meta_manager.cpp | 6 +-
be/src/olap/tablet_meta_manager.h | 2 +-
be/src/olap/task/engine_batch_load_task.cpp | 2 +-
be/src/olap/task/engine_checksum_task.cpp | 2 +-
be/src/olap/task/engine_clone_task.cpp | 4 +-
be/src/olap/task/engine_index_change_task.cpp | 2 +-
be/src/olap/task/engine_publish_version_task.cpp | 11 +-
be/src/olap/task/engine_publish_version_task.h | 7 +-
be/src/olap/task/index_builder.cpp | 2 +-
be/src/pipeline/exec/aggregation_sink_operator.cpp | 3 +-
be/src/pipeline/exec/exchange_sink_buffer.cpp | 30 +-
.../exec/nested_loop_join_build_operator.cpp | 8 +-
.../exec/nested_loop_join_build_operator.h | 3 +-
.../pipeline/exec/partition_sort_sink_operator.cpp | 2 -
.../exec/partitioned_aggregation_sink_operator.cpp | 4 +-
.../partitioned_aggregation_source_operator.cpp | 3 +-
.../exec/partitioned_hash_join_probe_operator.cpp | 52 +-
.../exec/partitioned_hash_join_sink_operator.cpp | 28 +-
.../exec/partitioned_hash_join_sink_operator.h | 1 +
be/src/pipeline/exec/scan_operator.cpp | 3 +-
be/src/pipeline/exec/spill_sort_sink_operator.cpp | 9 +-
.../pipeline/exec/spill_sort_source_operator.cpp | 7 +-
be/src/pipeline/pipeline_fragment_context.cpp | 14 +-
be/src/pipeline/pipeline_fragment_context.h | 2 +
be/src/pipeline/pipeline_task.cpp | 1 +
be/src/pipeline/pipeline_tracing.cpp | 8 +-
be/src/pipeline/pipeline_tracing.h | 2 +-
.../local_exchange_sink_operator.cpp | 17 +-
.../local_exchange/local_exchange_sink_operator.h | 2 +
be/src/pipeline/pipeline_x/operator.cpp | 52 +-
be/src/pipeline/pipeline_x/operator.h | 78 +
.../pipeline_x/pipeline_x_fragment_context.cpp | 19 +-
be/src/pipeline/pipeline_x/pipeline_x_task.cpp | 99 +-
be/src/pipeline/pipeline_x/pipeline_x_task.h | 2 +
be/src/pipeline/task_scheduler.cpp | 8 +-
be/src/runtime/client_cache.cpp | 2 +-
be/src/runtime/exec_env.h | 34 +-
be/src/runtime/exec_env_init.cpp | 32 +-
be/src/runtime/fold_constant_executor.cpp | 12 +-
be/src/runtime/fold_constant_executor.h | 2 +-
be/src/runtime/fragment_mgr.cpp | 34 +-
be/src/runtime/fragment_mgr.h | 2 +
be/src/runtime/group_commit_mgr.cpp | 14 +-
be/src/runtime/group_commit_mgr.h | 9 +-
be/src/runtime/load_channel.cpp | 15 +
be/src/runtime/load_channel.h | 4 +-
be/src/runtime/load_stream.cpp | 20 +
be/src/runtime/load_stream.h | 1 +
be/src/runtime/load_stream_writer.cpp | 5 +
be/src/runtime/load_stream_writer.h | 1 +
be/src/runtime/memory/cache_policy.h | 11 +-
be/src/runtime/memory/lru_cache_policy.h | 31 +-
be/src/runtime/memory/lru_cache_value_base.h | 11 +-
be/src/runtime/memory/mem_tracker.cpp | 2 +-
be/src/runtime/memory/mem_tracker_limiter.cpp | 199 +-
be/src/runtime/memory/mem_tracker_limiter.h | 71 +-
be/src/runtime/memory/thread_mem_tracker_mgr.cpp | 12 +-
be/src/runtime/memory/thread_mem_tracker_mgr.h | 9 +-
be/src/runtime/plan_fragment_executor.cpp | 19 +-
be/src/runtime/plan_fragment_executor.h | 2 +
be/src/runtime/query_context.cpp | 38 +-
be/src/runtime/query_context.h | 30 +
be/src/runtime/runtime_filter_mgr.cpp | 18 +-
be/src/runtime/runtime_filter_mgr.h | 7 +-
be/src/runtime/runtime_state.cpp | 74 +-
be/src/runtime/runtime_state.h | 12 +-
be/src/runtime/thread_context.cpp | 19 +
be/src/runtime/thread_context.h | 173 +-
be/src/runtime/workload_group/workload_group.cpp | 28 +-
be/src/runtime/workload_group/workload_group.h | 46 +-
.../workload_group/workload_group_manager.cpp | 123 +
.../workload_group/workload_group_manager.h | 2 +
be/src/service/backend_service.cpp | 4 +
be/src/service/internal_service.cpp | 5 +
be/src/service/point_query_executor.cpp | 13 +
be/src/service/point_query_executor.h | 3 +
be/src/util/brpc_client_cache.h | 4 +-
be/src/util/dns_cache.cpp | 84 +
be/src/{common/daemon.h => util/dns_cache.h} | 50 +-
be/src/util/mysql_row_buffer.cpp | 151 +-
be/src/vec/columns/subcolumn_tree.h | 37 +-
be/src/vec/common/allocator.cpp | 36 +-
be/src/vec/core/block.cpp | 9 +
be/src/vec/core/block.h | 8 +-
be/src/vec/exec/jni_connector.cpp | 11 +-
be/src/vec/exec/scan/pip_scanner_context.h | 6 +-
be/src/vec/exec/scan/scanner_context.cpp | 2 +-
be/src/vec/exec/scan/scanner_context.h | 21 +-
be/src/vec/exec/scan/scanner_scheduler.cpp | 6 +-
be/src/vec/exec/scan/vscan_node.h | 2 +
be/src/vec/exec/scan/vscanner.cpp | 94 +-
be/src/vec/exec/scan/vscanner.h | 12 +-
be/src/vec/exec/vpartition_sort_node.cpp | 2 -
.../function_date_or_datetime_computation.h | 14 +-
be/src/vec/functions/like.cpp | 2 +-
be/src/vec/runtime/vdatetime_value.h | 8 +-
be/src/vec/runtime/vorc_transformer.cpp | 104 +-
be/src/vec/runtime/vorc_transformer.h | 10 +-
be/src/vec/runtime/vparquet_transformer.cpp | 32 +-
be/src/vec/runtime/vparquet_transformer.h | 10 +-
be/src/vec/sink/group_commit_block_sink.cpp | 2 +-
be/src/vec/sink/load_stream_stub.cpp | 1 -
be/src/vec/sink/vdata_stream_sender.cpp | 1 -
be/src/vec/sink/vdata_stream_sender.h | 2 +-
be/src/vec/sink/writer/async_result_writer.cpp | 1 +
be/src/vec/sink/writer/vhive_partition_writer.cpp | 126 +-
be/src/vec/sink/writer/vhive_partition_writer.h | 6 +-
be/src/vec/sink/writer/vhive_table_writer.cpp | 23 +-
be/src/vec/sink/writer/vhive_table_writer.h | 3 +
be/src/vec/sink/writer/vtablet_writer.cpp | 2 -
be/src/vec/spill/spill_stream.h | 2 +
be/src/vec/spill/spill_writer.cpp | 23 +-
be/src/vec/spill/spill_writer.h | 5 +-
be/test/exprs/runtime_filter_test.cpp | 5 +-
be/test/olap/page_cache_test.cpp | 6 +-
be/test/olap/tablet_meta_manager_test.cpp | 4 +-
be/test/runtime/mem_limit_test.cpp | 2 +-
be/test/testutil/run_all_tests.cpp | 4 +
be/test/tools/benchmark_tool.cpp | 4 +-
.../serde/data_type_serde_mysql_test.cpp | 3 +-
be/test/vec/exec/parquet/parquet_reader_test.cpp | 1 -
be/test/vec/exec/vtablet_sink_test.cpp | 12 +-
be/test/vec/exec/vwal_scanner_test.cpp | 1 -
be/test/vec/exprs/vexpr_test.cpp | 6 +-
be/test/vec/runtime/vdata_stream_test.cpp | 3 +-
bin/start_be.sh | 2 +
build-for-release.sh | 1 -
build.sh | 20 -
cloud/src/common/sync_point.cpp | 3 -
cloud/src/meta-service/codec.cpp | 2 -
cloud/src/meta-service/keys.cpp | 4 -
conf/be.conf | 13 +-
conf/fe.conf | 19 +-
.../sql-functions/date-time-functions/timediff.md | 11 +-
.../sql-functions/date-time-functions/timediff.md | 10 +-
.../sql-manual/sql-reference/Data-Types/VARIANT.md | 4 +-
.../main/java/org/apache/doris/common/Config.java | 14 +-
.../java/org/apache/doris/common/io/DiskUtils.java | 1 -
fe/fe-core/src/main/cup/sql_parser.cup | 5 +
.../doris/analysis/CreateMaterializedViewStmt.java | 4 +
.../doris/analysis/CreateStorageVaultStmt.java | 12 +-
.../main/java/org/apache/doris/analysis/Expr.java | 9 +
.../java/org/apache/doris/analysis/GrantStmt.java | 198 +-
.../java/org/apache/doris/analysis/RevokeStmt.java | 6 +-
.../apache/doris/analysis/ShowPrivilegesStmt.java | 41 +-
.../java/org/apache/doris/analysis/SlotRef.java | 5 +
.../apache/doris/binlog/AddPartitionRecord.java | 2 +-
.../java/org/apache/doris/catalog/Database.java | 2 +-
.../java/org/apache/doris/catalog/DatabaseIf.java | 4 +-
.../main/java/org/apache/doris/catalog/Env.java | 12 +-
.../java/org/apache/doris/catalog/Partition.java | 4 +
.../apache/doris/catalog/RangePartitionItem.java | 2 +-
.../org/apache/doris/catalog/StorageVault.java | 1 +
.../apache/doris/cloud/catalog/CloudPartition.java | 5 +
.../cloud/planner/CloudStreamLoadPlanner.java | 12 +
.../java/org/apache/doris/common/DNSCache.java | 95 +
.../java/org/apache/doris/common/ErrorCode.java | 2 +
.../java/org/apache/doris/common/Log4jConfig.java | 5 +-
.../org/apache/doris/common/util/NetUtils.java | 16 +-
.../apache/doris/datasource/ExternalCatalog.java | 13 -
.../doris/datasource/ExternalMetaCacheMgr.java | 3 +-
.../doris/datasource/ExternalRowCountCache.java | 13 +-
.../hive/PostgreSQLJdbcHMSCachedClient.java | 30 +-
.../datasource/iceberg/IcebergMetadataOps.java | 14 +-
.../doris/datasource/iceberg/IcebergUtils.java | 214 +-
.../TrinoConnectorExternalCatalog.java | 12 +-
.../source/TrinoConnectorScanNode.java | 2 +-
.../source/TrinoConnectorSource.java | 7 +
.../trinoconnector/source/TrinoConnectorSplit.java | 44 +-
.../doris/httpv2/controller/LogController.java | 3 +-
.../org/apache/doris/httpv2/rest/LoadAction.java | 19 +-
.../org/apache/doris/load/StreamLoadHandler.java | 278 +
.../apache/doris/load/loadv2/MysqlLoadManager.java | 22 +-
.../apache/doris/mysql/privilege/Privilege.java | 51 +-
.../glue/translator/PlanTranslatorContext.java | 2 +-
.../glue/translator/RuntimeFilterTranslator.java | 4 +-
.../doris/nereids/parser/PartitionTableInfo.java | 7 +-
.../DistributionSpecTableSinkHashPartitioned.java | 3 -
.../doris/nereids/rules/analysis/BindSink.java | 7 -
.../rules/OneRangePartitionEvaluator.java | 23 +
...ogicalHiveTableSinkToPhysicalHiveTableSink.java | 3 +-
.../mv/AbstractSelectMaterializedIndexRule.java | 10 +-
.../executable/DateTimeExtractAndTransform.java | 457 +-
.../trees/expressions/literal/DateTimeLiteral.java | 2 +-
.../trees/plans/commands/info/CreateTableInfo.java | 35 +-
.../plans/commands/insert/HiveInsertExecutor.java | 22 +-
.../commands/insert/InsertIntoTableCommand.java | 7 +-
.../trees/plans/logical/LogicalHiveTableSink.java | 19 +-
.../trees/plans/physical/PhysicalHashJoin.java | 8 +-
.../plans/physical/PhysicalHiveTableSink.java | 24 +-
.../org/apache/doris/planner/AggregationNode.java | 28 +-
.../org/apache/doris/planner/HiveTableSink.java | 10 +-
.../main/java/org/apache/doris/qe/Coordinator.java | 9 +-
.../java/org/apache/doris/qe/SessionVariable.java | 27 +-
.../java/org/apache/doris/qe/ShowExecutor.java | 15 +
.../java/org/apache/doris/qe/StmtExecutor.java | 15 +-
.../org/apache/doris/rpc/BackendServiceProxy.java | 4 +-
.../java/org/apache/doris/service/ExecuteEnv.java | 6 +-
.../apache/doris/service/FrontendServiceImpl.java | 368 +-
.../apache/doris/statistics/AnalysisManager.java | 2 +-
fe/fe-core/src/main/jflex/sql_scanner.flex | 1 +
.../org/apache/doris/catalog/DatabaseTest.java | 6 +-
.../doris/cloud/catalog/HdfsStorageVaultTest.java | 15 +-
.../apache/doris/datasource/CatalogMgrTest.java | 4 -
.../datasource/ExternalRowCountCacheTest.java | 100 +
.../datasource/hive/HiveDDLAndDMLPlanTest.java | 179 +-
.../datasource/iceberg/TestIcebergPredict.java | 135 +
.../org/apache/doris/mysql/privilege/AuthTest.java | 11 +-
gensrc/thrift/DataSinks.thrift | 3 +-
gensrc/thrift/PlanNodes.thrift | 5 +-
.../test_inlineview_with_project.out | 6 +
.../hive/ddl/test_hive_ddl_and_ctas.out | 148 +
.../hive/jdbc_hive_meta/test_jdbc_hive_orc.out | 66 +-
.../hive/write/test_hive_write_insert.out | 66 +
.../hive/write/test_hive_write_partitions.out | 50 +
.../hive/test_external_catalog_glue_table.out | 3 +
regression-test/data/insert_p0/txn_insert.out | 6 +
.../k1s2m3_auto_inc.out} | 10 +-
.../multi_slot_k1a2p2ap3p.out | 6 +
.../data/nereids_p0/aggregate/aggregate.out | 2 +
.../datetime_functions/test_time_lut.out | 25200 +++++++++++++++++++
.../partition_prune/test_nullsafe_eq_prune.out} | 13 +-
.../test_function_regexp_passall.out | 37 +
.../datetime_functions/test_time_diff.out | 4 +-
.../data/variant_github_events_p0/load.out | 4 +-
regression-test/data/variant_p0/column_name.out | 12 +
.../cloud_p0/conf/regression-conf-custom.groovy | 2 +
.../cloud_p1/conf/regression-conf-custom.groovy | 1 +
.../pipeline/external/conf/regression-conf.groovy | 2 -
.../pipeline/p0/conf/regression-conf.groovy | 2 -
.../performance/clickbench/check-query-result.sh | 2 +-
.../query-result-target/doris-q10.result | 2 +-
.../query-result-target/doris-q28.result | 24 +-
.../query-result-target/doris-q29.result | 52 +-
.../query-result-target/doris-q31.result | 6 +-
.../suites/account_p0/test_grant_priv.groovy | 86 +
.../account_p0/test_grant_priv_resource.groovy | 57 +
.../account_p0/test_grant_priv_workload.groovy | 57 +
.../test_show_privileges.groovy} | 15 +-
.../test_inlineview_with_project.groovy | 102 +
.../hive/ddl/test_hive_ddl_and_ctas.groovy | 423 +
.../hive/write/test_hive_write_insert.groovy | 786 +-
.../hive/write/test_hive_write_partitions.groovy | 3 +-
.../hive/test_external_catalog_glue_table.groovy | 1 +
regression-test/suites/insert_p0/txn_insert.groovy | 29 +
.../k1s2m3_auto_inc.groovy} | 26 +-
.../multi_slot_k1a2p2ap3p.groovy | 2 +
.../suites/nereids_p0/aggregate/aggregate.groovy | 6 +
.../datetime_functions/test_time_lut.groovy | 84 +
.../suites/nereids_p0/test_mv_select.groovy | 50 +
...cross_join_range_number_increment_create.groovy | 4 +-
.../full_join_range_number_increment_create.groovy | 4 +-
...inner_join_range_number_increment_create.groovy | 4 +-
..._anti_join_range_number_increment_create.groovy | 4 +-
.../left_join_range_number_increment_create.groovy | 4 +-
..._semi_join_range_number_increment_create.groovy | 4 +-
..._anti_join_range_number_increment_create.groovy | 4 +-
...right_join_range_number_increment_create.groovy | 4 +-
..._semi_join_range_number_increment_create.groovy | 4 +-
.../self_conn_range_number_increment_create.groovy | 4 +-
.../partition_prune/test_nullsafe_eq_prune.groovy | 56 +
.../test_function_regexp_passall.groovy | 52 +
.../schema_change_p0/test_rename_column.groovy | 6 +-
.../suites/variant_github_events_p0/load.groovy | 2 +-
.../suites/variant_p0/column_name.groovy | 8 +-
.../workload_manager_p0/test_curd_wlg.groovy | 52 +-
325 files changed, 31311 insertions(+), 2447 deletions(-)
create mode 100644 be/src/util/dns_cache.cpp
copy be/src/{common/daemon.h => util/dns_cache.h} (52%)
copy be/src/olap/rowset/pending_rowset_helper.cpp =>
fe/fe-core/src/main/java/org/apache/doris/analysis/ShowPrivilegesStmt.java (52%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/common/DNSCache.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/load/StreamLoadHandler.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/ExternalRowCountCacheTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/iceberg/TestIcebergPredict.java
create mode 100644
regression-test/data/external_table_p0/hive/ddl/test_hive_ddl_and_ctas.out
copy
regression-test/data/mv_p0/{multi_slot_k1a2p2ap3p/multi_slot_k1a2p2ap3p.out =>
k1s2m3_auto_inc/k1s2m3_auto_inc.out} (77%)
copy
regression-test/data/{mv_p0/multi_slot_k1a2p2ap3p/multi_slot_k1a2p2ap3p.out =>
nereids_rules_p0/partition_prune/test_nullsafe_eq_prune.out} (51%)
create mode 100644
regression-test/data/nereids_syntax_p0/test_function_regexp_passall.out
create mode 100644 regression-test/suites/account_p0/test_grant_priv.groovy
create mode 100644
regression-test/suites/account_p0/test_grant_priv_resource.groovy
create mode 100644
regression-test/suites/account_p0/test_grant_priv_workload.groovy
copy
regression-test/suites/{nereids_p0/sql_functions/datetime_functions/test_time_lut.groovy
=> account_p0/test_show_privileges.groovy} (63%)
create mode 100644
regression-test/suites/external_table_p0/hive/ddl/test_hive_ddl_and_ctas.groovy
copy
regression-test/suites/mv_p0/{multi_slot_k1a2p2ap3p/multi_slot_k1a2p2ap3p.groovy
=> k1s2m3_auto_inc/k1s2m3_auto_inc.groovy} (61%)
create mode 100644
regression-test/suites/nereids_rules_p0/partition_prune/test_nullsafe_eq_prune.groovy
create mode 100644
regression-test/suites/nereids_syntax_p0/test_function_regexp_passall.groovy
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
