This is an automated email from the ASF dual-hosted git repository.
panxiaolei pushed a change to branch refactor_rf
in repository https://gitbox.apache.org/repos/asf/doris.git
discard 77d4569fb73 add runtime filter helper
discard bfabfe4b9fc move directory
discard 9ca04ae3c91 rename consumer
discard de40d4af5ab refactor of RuntimeFilter
discard 47530f58191 refactor of RuntimeFilterSlots
add a5468a924ef [log](regression)Add log for failed analyze task and the
regression case. (#47635)
add 16fbce821a6 [fix](resource) Fix `MemTableWriter` attach resource
context to thread context (#47556)
add a14872b1073 [Fix](recycler) Fix recycler pipeline case check_meta
(#47646)
add fa09d46f28f [improvement](test) improvement case compatible with multi
platform(l… (#47654)
add b1e7432a311 [opt](kerberos) use ticket cache instead of
principal+keytab on BE side (#47299)
add 982e733ac8c [fix](nereids)keep at least one hash output slot when
prune slots in hash join node (#47318)
add 6120614192c [Enhancement] (nereids)implement alterRepositoryCommand in
nereids (#46838)
add 0ef0ff18307 [Chore](case) drop expr_tes2 on nereids_arith_p0.load
(#47671)
add 6bfc1fa82dd [fix](cases)rename test case file name (#47677)
add fbdb4f401c3 [fix](function)Fix split_by_regexp function integer
parameter couldn't set bug. (#47676)
add 8417544e7e2 [test](hudi) add more hudi jni test cases (#47431)
add e5f4deab770 [Fix](catalog)Fixes query failures for Paimon tables
stored in Kerberized HDFS (#47192)
add e8c44a7fee1 [feature](neredis)Support show analyze in Nereids. (#47280)
add ac264d735f1 [fix](mv)Fix direct select mv pre agg bug. (#47658)
add 863a652011e [fix](ES Catalog)Make sure ES meta is synced before using
(#46781)
add e9c2040083b [test](beut) add pipeline operator be ut case (#47599)
add 3f33c5a1e5e [chore](file cache) Disable show cache hotspot stmt
(#47332)
add 68b6a547f0c [opt](log) Add some logs for recycler (#47600)
add 1dcf4d1f447 [log](mow) reduce log for data load on mow table (#47647)
add 60a0d8f4e12 [Fix](regression) Fix case `test_add_key_partial_update`
(#47583)
add 6dcbd69729a [improve](load) improve error messages for "no backend
available" (#47510)
add 2d8a86286b7 [improve](move-memtable) improve error log and message for
"not enough streams" (#47470)
add 51293ee405b [Enhancement](Test) Add ut for delete tmp rowset (#47581)
add 53337edec95 [fix](ut) fix cases for rename file name link pr 47677
(#47706)
add 9f42075eeea [fix](external catalog) Fix missing fields when rebuilding
metadata from image (#47603)
add 5d7b7c560bc [fix](coordinator) Fix wrong `recvrId` in fragment
contains BHJ (#47727)
add ac83d85e10d [fix](orc) remove unnecessary fields of orc_reader (#47506)
add 609118ecc76 [env](compile) add compiler check and fix some clang-tidy
suggestions for vec/exec/format (#45881)
add b0e5e09c362 [Fix](memory) Add try catch block for
`Segment::load_pk_index_and_bf` (#47715)
add 6a5c1efe638 [chore](github)Delete inactive collaborators (#47740)
add 51a6b14eb6c [refactor](merger) Simplify sort merger (#47689)
add cf2fcf9f09f [fix](github)Fix the incorrect format of branch-3.0
.asf.yaml (#47745)
add 538ce5585d6 [fix](Nereids) fix log bug and add more numeric arithmetic
function cases (#47228)
add 6f8f4c86746 [fix](be) fix be compile error (#47750)
add 634547204f9 [regression-test](fix) sleep after mv job finished (#47573)
add 9034b0c34a9 [regression-test](suite) add sleep to
waitingMVTaskFinishedByMvName (#47549)
add cbcebb114cb [test](cloud-mow)Add update big delete bitmap case (#47097)
add b007b96b273 [opt](debug) remove redundant DCHECK to allow graceful
error handling (#47644)
add 3c1d7d27269 [improve](functon) improve json_object with complex type
(#47627)
add dea505607ea [opt](paimon) Optimize error prompt (#47593)
add 1738a56dc9d [UT](exchanger) Add UT case to test local merge exchanger
(#47787)
add 8764a01d6ca [fix](restore) Filter partition property storage policy in
synced table (#47690)
add 44b50e1cf7c [Test](cbq) Filter checks for light_schema_change (#47758)
add 02bc33c0b06 refactor of RuntimeFilterSlots
add f4ef87b06ca refactor of RuntimeFilter
add 0595f8718cf rename consumer
add 25dbec1fef4 move directory
add 6639775ad93 add runtime filter helper
add 8df75b4c2d5 update role state system
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 (77d4569fb73)
\
N -- N -- N refs/heads/refactor_rf (8df75b4c2d5)
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:
.asf.yaml | 4 +-
be/CMakeLists.txt | 3 +
.../cloud/cloud_engine_calc_delete_bitmap_task.cpp | 8 -
be/src/cloud/cloud_meta_mgr.cpp | 18 +
be/src/cloud/cloud_txn_delete_bitmap_cache.cpp | 5 -
be/src/common/config.cpp | 3 +-
be/src/common/config.h | 2 +
.../common/kerberos/kerberos_config.cpp} | 35 +-
be/src/common/kerberos/kerberos_config.h | 77 +++
be/src/common/kerberos/kerberos_ticket_cache.cpp | 304 +++++++++
be/src/common/kerberos/kerberos_ticket_cache.h | 142 +++++
be/src/common/kerberos/kerberos_ticket_mgr.cpp | 178 ++++++
be/src/common/kerberos/kerberos_ticket_mgr.h | 109 ++++
be/src/common/kerberos/krb5_interface.h | 74 +++
be/src/common/kerberos/krb5_interface_impl.cpp | 153 +++++
be/src/common/kerberos/krb5_interface_impl.h | 59 ++
be/src/exec/schema_scanner.cpp | 3 +
...pp => schema_backend_kerberos_ticket_cache.cpp} | 68 +-
...er.h => schema_backend_kerberos_ticket_cache.h} | 15 +-
.../exec/schema_scanner/schema_scanner_helper.cpp | 19 +
be/src/exec/schema_scanner/schema_scanner_helper.h | 4 +
be/src/io/file_factory.cpp | 5 +-
be/src/io/fs/hdfs/hdfs_mgr.cpp | 254 ++++++++
be/src/io/fs/hdfs/hdfs_mgr.h | 90 +++
be/src/io/fs/hdfs_file_system.cpp | 46 +-
be/src/io/fs/hdfs_file_system.h | 2 +-
be/src/io/fs/hdfs_file_writer.cpp | 1 -
be/src/io/hdfs_builder.cpp | 110 ++--
be/src/io/hdfs_builder.h | 24 +-
be/src/io/hdfs_util.cpp | 141 -----
be/src/io/hdfs_util.h | 106 +---
be/src/olap/base_tablet.cpp | 34 +-
be/src/olap/memtable_writer.cpp | 10 +-
be/src/olap/push_handler.h | 4 +-
be/src/olap/rowset/segment_v2/segment.cpp | 10 +-
be/src/olap/rowset_builder.cpp | 2 -
be/src/pipeline/exec/assert_num_rows_operator.h | 4 +
be/src/pipeline/exec/datagen_operator.h | 3 +
be/src/pipeline/exec/empty_set_operator.h | 4 +
be/src/pipeline/exec/exchange_source_operator.cpp | 2 +-
be/src/pipeline/exec/hashjoin_build_sink.cpp | 3 +-
be/src/pipeline/exec/mock_operator.h | 67 ++
be/src/pipeline/exec/operator.cpp | 4 +
be/src/pipeline/exec/operator.h | 21 +
be/src/pipeline/exec/sort_source_operator.cpp | 13 -
be/src/pipeline/exec/sort_source_operator.h | 5 +-
.../local_exchange/local_exchange_sink_operator.h | 9 +
.../local_exchange_source_operator.h | 3 +
be/src/pipeline/local_exchange/local_exchanger.cpp | 25 +-
be/src/pipeline/local_exchange/local_exchanger.h | 21 +-
be/src/pipeline/pipeline_fragment_context.cpp | 5 +-
be/src/runtime/exec_env.h | 11 +
be/src/runtime/exec_env_init.cpp | 14 +
be/src/runtime/load_channel.cpp | 1 -
be/src/runtime/load_channel.h | 2 +
be/src/runtime/load_channel_mgr.cpp | 1 +
be/src/runtime/memory/thread_mem_tracker_mgr.cpp | 16 +-
be/src/runtime/memory/thread_mem_tracker_mgr.h | 22 +-
be/src/runtime/runtime_filter_mgr.cpp | 15 +-
be/src/runtime/runtime_filter_mgr.h | 3 +-
be/src/runtime/thread_context.cpp | 46 +-
be/src/runtime/thread_context.h | 32 +-
be/src/runtime_filter/runtime_filter.cpp | 30 +-
be/src/runtime_filter/runtime_filter.h | 24 +-
be/src/runtime_filter/runtime_filter_consumer.cpp | 34 +-
be/src/runtime_filter/runtime_filter_consumer.h | 48 +-
be/src/runtime_filter/runtime_filter_definitions.h | 29 -
be/src/runtime_filter/runtime_filter_helper.cpp | 54 +-
be/src/runtime_filter/runtime_filter_helper.h | 11 +-
be/src/runtime_filter/runtime_filter_merger.h | 32 +-
be/src/runtime_filter/runtime_filter_producer.cpp | 29 +-
be/src/runtime_filter/runtime_filter_producer.h | 55 +-
be/src/runtime_filter/runtime_filter_slots.cpp | 18 +-
be/src/runtime_filter/runtime_filter_slots.h | 15 +-
be/src/runtime_filter/runtime_filter_wrapper.cpp | 252 ++++----
be/src/runtime_filter/runtime_filter_wrapper.h | 89 ++-
be/src/runtime_filter/utils.cpp | 32 -
be/src/runtime_filter/utils.h | 2 -
be/src/util/jni-util.cpp | 10 +-
be/src/util/string_parser.hpp | 3 +-
be/src/vec/common/sort/heap_sorter.cpp | 4 +-
be/src/vec/common/sort/sorter.cpp | 4 +-
be/src/vec/common/sort/vsort_exec_exprs.cpp | 27 +-
be/src/vec/common/sort/vsort_exec_exprs.h | 16 +-
be/src/vec/core/sort_cursor.h | 21 +-
be/src/vec/data_types/data_type_ipv4.h | 8 +-
.../vec/data_types/serde/data_type_array_serde.cpp | 52 +-
.../vec/data_types/serde/data_type_array_serde.h | 18 +-
.../data_types/serde/data_type_bitmap_serde.cpp | 2 +-
.../vec/data_types/serde/data_type_bitmap_serde.h | 6 +-
.../data_types/serde/data_type_date64_serde.cpp | 30 +-
.../vec/data_types/serde/data_type_date64_serde.h | 8 +-
.../serde/data_type_datetimev2_serde.cpp | 13 +-
.../data_types/serde/data_type_datetimev2_serde.h | 12 +-
.../data_types/serde/data_type_datev2_serde.cpp | 15 +-
.../vec/data_types/serde/data_type_datev2_serde.h | 12 +-
.../data_types/serde/data_type_decimal_serde.cpp | 17 +-
.../vec/data_types/serde/data_type_decimal_serde.h | 12 +-
.../vec/data_types/serde/data_type_hll_serde.cpp | 2 +-
be/src/vec/data_types/serde/data_type_hll_serde.h | 6 +-
.../vec/data_types/serde/data_type_ipv4_serde.cpp | 4 +-
be/src/vec/data_types/serde/data_type_ipv4_serde.h | 4 +-
.../vec/data_types/serde/data_type_ipv6_serde.cpp | 6 +-
be/src/vec/data_types/serde/data_type_ipv6_serde.h | 4 +-
.../vec/data_types/serde/data_type_jsonb_serde.cpp | 2 +-
.../vec/data_types/serde/data_type_jsonb_serde.h | 2 +-
.../vec/data_types/serde/data_type_map_serde.cpp | 32 +-
be/src/vec/data_types/serde/data_type_map_serde.h | 8 +-
.../vec/data_types/serde/data_type_nothing_serde.h | 6 +-
.../data_types/serde/data_type_nullable_serde.cpp | 18 +-
.../data_types/serde/data_type_nullable_serde.h | 12 +-
.../data_types/serde/data_type_number_serde.cpp | 22 +-
.../vec/data_types/serde/data_type_number_serde.h | 12 +-
.../vec/data_types/serde/data_type_object_serde.h | 6 +-
.../serde/data_type_quantilestate_serde.h | 6 +-
be/src/vec/data_types/serde/data_type_serde.h | 24 +-
.../vec/data_types/serde/data_type_string_serde.h | 14 +-
.../data_types/serde/data_type_struct_serde.cpp | 24 +-
.../vec/data_types/serde/data_type_struct_serde.h | 12 +-
be/src/vec/data_types/serde/data_type_time_serde.h | 5 +-
.../exec/format/arrow/arrow_pip_input_stream.cpp | 20 +-
.../vec/exec/format/arrow/arrow_pip_input_stream.h | 14 +-
.../vec/exec/format/arrow/arrow_stream_reader.cpp | 16 +-
be/src/vec/exec/format/arrow/arrow_stream_reader.h | 6 +-
be/src/vec/exec/format/avro/avro_jni_reader.cpp | 10 +-
be/src/vec/exec/format/avro/avro_jni_reader.h | 10 +-
be/src/vec/exec/format/column_type_convert.cpp | 4 +-
be/src/vec/exec/format/column_type_convert.h | 45 +-
be/src/vec/exec/format/csv/csv_reader.cpp | 24 +-
be/src/vec/exec/format/csv/csv_reader.h | 23 +-
.../file_reader/new_plain_binary_line_reader.cpp | 6 +-
.../file_reader/new_plain_binary_line_reader.h | 7 +-
.../file_reader/new_plain_text_line_reader.cpp | 16 +-
.../file_reader/new_plain_text_line_reader.h | 27 +-
be/src/vec/exec/format/format_common.h | 4 +-
be/src/vec/exec/format/generic_reader.h | 10 +-
be/src/vec/exec/format/jni_reader.cpp | 6 +-
be/src/vec/exec/format/jni_reader.h | 5 +-
be/src/vec/exec/format/json/new_json_reader.cpp | 45 +-
be/src/vec/exec/format/json/new_json_reader.h | 21 +-
be/src/vec/exec/format/orc/orc_memory_pool.h | 2 +
be/src/vec/exec/format/orc/vorc_reader.cpp | 252 ++++----
be/src/vec/exec/format/orc/vorc_reader.h | 84 +--
be/src/vec/exec/format/parquet/schema_desc.cpp | 2 +-
be/src/vec/exec/format/parquet/schema_desc.h | 4 +-
.../exec/format/parquet/vparquet_group_reader.cpp | 2 +-
be/src/vec/exec/format/parquet/vparquet_reader.cpp | 1 +
be/src/vec/exec/format/table/equality_delete.cpp | 13 +-
be/src/vec/exec/format/table/equality_delete.h | 4 +-
be/src/vec/exec/format/table/hudi_jni_reader.cpp | 8 +-
be/src/vec/exec/format/table/hudi_jni_reader.h | 3 +-
.../format/table/iceberg/arrow_schema_util.cpp | 10 +-
.../exec/format/table/iceberg/arrow_schema_util.h | 10 +-
.../exec/format/table/iceberg/partition_spec.cpp | 9 +-
.../vec/exec/format/table/iceberg/partition_spec.h | 10 +-
.../format/table/iceberg/partition_spec_parser.cpp | 10 +-
.../format/table/iceberg/partition_spec_parser.h | 8 +-
be/src/vec/exec/format/table/iceberg/schema.cpp | 8 +-
be/src/vec/exec/format/table/iceberg/schema.h | 8 +-
.../exec/format/table/iceberg/schema_parser.cpp | 13 +-
.../vec/exec/format/table/iceberg/schema_parser.h | 8 +-
be/src/vec/exec/format/table/iceberg/struct_like.h | 10 +-
be/src/vec/exec/format/table/iceberg/types.cpp | 13 +-
be/src/vec/exec/format/table/iceberg/types.h | 79 ++-
.../table/iceberg/unbound_partition_spec.cpp | 13 +-
.../format/table/iceberg/unbound_partition_spec.h | 8 +-
be/src/vec/exec/format/table/iceberg_reader.cpp | 69 +-
be/src/vec/exec/format/table/iceberg_reader.h | 12 +-
.../vec/exec/format/table/lakesoul_jni_reader.cpp | 8 +-
be/src/vec/exec/format/table/lakesoul_jni_reader.h | 2 +
.../exec/format/table/max_compute_jni_reader.cpp | 8 +-
.../vec/exec/format/table/max_compute_jni_reader.h | 7 +-
be/src/vec/exec/format/table/paimon_jni_reader.cpp | 12 +-
be/src/vec/exec/format/table/paimon_jni_reader.h | 4 +-
be/src/vec/exec/format/table/paimon_reader.cpp | 2 +
be/src/vec/exec/format/table/paimon_reader.h | 2 +
.../vec/exec/format/table/table_format_reader.cpp | 25 -
be/src/vec/exec/format/table/table_format_reader.h | 17 +-
.../format/table/transactional_hive_common.cpp | 2 +
.../exec/format/table/transactional_hive_common.h | 2 +
.../format/table/transactional_hive_reader.cpp | 37 +-
.../exec/format/table/transactional_hive_reader.h | 15 +-
.../format/table/trino_connector_jni_reader.cpp | 6 +-
.../exec/format/table/trino_connector_jni_reader.h | 7 +-
be/src/vec/exec/format/wal/wal_reader.cpp | 12 +-
be/src/vec/exec/format/wal/wal_reader.h | 8 +-
be/src/vec/exec/scan/vfile_scanner.cpp | 4 +-
be/src/vec/exec/scan/vfile_scanner.h | 2 +-
be/src/vec/functions/function_json.cpp | 17 +-
be/src/vec/runtime/shared_hash_table_controller.h | 3 +-
be/src/vec/sink/writer/vtablet_writer_v2.cpp | 21 +-
be/test/common/kerberos/kerberos_config_test.cpp | 60 ++
.../kerberos/kerberos_ticket_cache_auth_test.cpp | 133 ++++
.../common/kerberos/kerberos_ticket_cache_test.cpp | 242 +++++++
.../common/kerberos/kerberos_ticket_mgr_test.cpp | 141 +++++
be/test/io/fs/hdfs/hdfs_mgr_test.cpp | 362 +++++++++++
be/test/pipeline/local_exchanger_test.cpp | 284 +++++++++
.../operator/assert_nums_rows_operator.cpp | 111 ++++
.../pipeline/operator/datagen_operator_test.cpp | 130 ++++
.../pipeline/operator/empty_set_operator_test.cpp} | 24 +-
be/test/pipeline/operator/operator_helper.h | 48 ++
.../runtime/memory/thread_mem_tracker_mgr_test.cpp | 10 +-
be/test/testutil/column_helper.h | 10 +
.../vec/data_types/common_data_type_serder_test.h | 6 +-
be/test/vec/data_types/common_data_type_test.h | 8 +-
be/test/vec/data_types/data_type_array_test.cpp | 10 +-
be/test/vec/exec/sort/sort_test.cpp | 2 +-
cloud/src/recycler/recycler.cpp | 10 +-
cloud/test/recycler_test.cpp | 169 ++++-
.../apache/doris/hudi/HadoopHudiJniScanner.java | 55 +-
fe/be-java-extensions/paimon-scanner/pom.xml | 6 -
.../org/apache/doris/paimon/PaimonJniScanner.java | 30 +-
.../main/java/org/apache/doris/common/Config.java | 4 +
.../authentication/AuthenticationConfig.java | 17 +-
.../PreExecutionAuthenticatorCache.java | 87 +++
.../antlr4/org/apache/doris/nereids/DorisParser.g4 | 11 +-
.../java/org/apache/doris/analysis/CastExpr.java | 4 +
.../apache/doris/analysis/FunctionCallExpr.java | 3 +
.../org/apache/doris/analysis/SchemaTableType.java | 4 +-
.../doris/analysis/ShowCacheHotSpotStmt.java | 5 +
.../org/apache/doris/backup/BackupHandler.java | 9 +-
.../java/org/apache/doris/catalog/EsTable.java | 18 +-
.../java/org/apache/doris/catalog/OlapTable.java | 1 +
.../java/org/apache/doris/catalog/SchemaTable.java | 16 +
.../apache/doris/datasource/ExternalCatalog.java | 23 +-
.../apache/doris/datasource/ExternalDatabase.java | 36 +-
.../apache/doris/datasource/InitCatalogLog.java | 7 +-
.../apache/doris/datasource/InitDatabaseLog.java | 7 +-
.../datasource/paimon/PaimonExternalCatalog.java | 16 +-
.../glue/translator/PhysicalPlanTranslator.java | 12 +
.../doris/nereids/parser/LogicalPlanBuilder.java | 23 +
.../doris/nereids/rules/analysis/BindRelation.java | 4 +-
.../functions/executable/NumericArithmetic.java | 6 +-
.../expressions/functions/scalar/JsonObject.java | 36 +-
.../functions/scalar/SplitByRegexp.java | 6 +-
.../apache/doris/nereids/trees/plans/PlanType.java | 2 +
.../trees/plans/commands/ShowAnalyzeCommand.java | 206 ++++++
.../commands/alter/AlterRepositoryCommand.java} | 48 +-
.../trees/plans/visitor/CommandVisitor.java | 11 +
.../planner/BackendPartitionedSchemaScanNode.java | 1 +
.../main/java/org/apache/doris/qe/Coordinator.java | 2 -
.../java/org/apache/doris/qe/StmtExecutor.java | 3 +-
.../apache/doris/statistics/AnalysisManager.java | 35 +-
.../apache/doris/statistics/BaseAnalysisTask.java | 3 +-
.../org/apache/doris/system/SystemInfoService.java | 10 +-
.../paimon/PaimonExternalCatalogTest.java} | 31 +-
gensrc/thrift/Descriptors.thrift | 3 +-
regression-test/conf/regression-conf.groovy | 7 -
.../test_column_prune_in_hash_join.out | Bin 0 -> 255 bytes
.../hudi/test_hudi_incremental.out | Bin 5687 -> 7551 bytes
.../hudi/test_hudi_schema_evolution.out | Bin 7521 -> 11234 bytes
.../external_table_p2/hudi/test_hudi_snapshot.out | Bin 696105 -> 1044838
bytes
.../hudi/test_hudi_timetravel.out | Bin 2111 -> 3119 bytes
...,double>.csv => test_array_map_char_double.csv} | 0
...6>>.csv => test_array_map_datetime_decimal.csv} | 0
...ipv4,ipv6>.csv => test_array_map_ipv4_ipv6.csv} | 0
...ing>.csv => test_array_map_largeInt_string.csv} | 0
.../query_p0/cast/test_complextype_to_json.out | Bin 2450 -> 2124 bytes
.../json_function/test_query_json_object.out | Bin 524 -> 1959 bytes
.../string_functions/test_split_by_regexp.out | Bin 764 -> 987 bytes
.../test_analyze_mv.out} | Bin 110 -> 124 bytes
.../org/apache/doris/regression/suite/Suite.groovy | 13 +-
.../test_alter_repository_command.groovy} | 22 +-
.../auth_call/test_dml_broker_load_auth.groovy | 3 +-
...y => test_backup_restore_storage_policy.groovy} | 111 ++--
.../check_before_quit/check_before_quit.groovy | 15 +-
...est_compaction_update_big_delete_bitmap.groovy} | 162 ++---
.../test_column_prune_in_hash_join.groovy | 131 ++++
.../test_mv_case/test_mv_case.groovy | 2 +
.../external_table_p0/es/test_es_query.groovy | 30 +-
.../es/test_es_query_no_http_url.groovy | 31 +-
.../kerberos/test_single_hive_kerberos.groovy | 16 +-
.../kerberos/test_two_hive_kerberos.groovy | 57 +-
.../es/test_external_catalog_es.groovy | 52 --
.../external_table_p2/es/test_external_es.groovy | 56 --
.../hudi/test_hudi_incremental.groovy | 18 +-
.../hudi/test_hudi_schema_evolution.groovy | 16 +-
.../hudi/test_hudi_snapshot.groovy | 10 +-
.../hudi/test_hudi_timetravel.groovy | 11 +-
.../test_add_key_partial_update.groovy | 2 +-
.../test_multi_replica_fault_injection.groovy | 2 +-
...t_domain_connection_and_ak_sk_correction.groovy | 12 +-
.../load_p0/broker_load/test_seq_load.groovy | 3 +-
.../stream_load/test_stream_load_error_url.groovy | 2 +-
.../suites/nereids_arith_p0/load.groovy | 1 +
.../fold_constant_numeric_arithmatic.groovy | 696 +++++++++++----------
.../json_function/test_query_json_object.groovy | 56 ++
.../string_functions/test_split_by_regexp.groovy | 6 +
.../test_dup_rollup_schema_change.groovy | 1 +
.../test_uniq_rollup_schema_change.groovy | 1 +
.../suites/statistics/analyze_stats.groovy | 24 +-
.../suites/statistics/test_analyze_mv.groovy | 19 +
.../suites/statistics/test_update_rows_mv.groovy | 2 +
.../workload_manager_p0/test_resource_tag.groovy | 6 +-
294 files changed, 6586 insertions(+), 2535 deletions(-)
copy be/{test/util/md5_test.cpp => src/common/kerberos/kerberos_config.cpp}
(52%)
create mode 100644 be/src/common/kerberos/kerberos_config.h
create mode 100644 be/src/common/kerberos/kerberos_ticket_cache.cpp
create mode 100644 be/src/common/kerberos/kerberos_ticket_cache.h
create mode 100644 be/src/common/kerberos/kerberos_ticket_mgr.cpp
create mode 100644 be/src/common/kerberos/kerberos_ticket_mgr.h
create mode 100644 be/src/common/kerberos/krb5_interface.h
create mode 100644 be/src/common/kerberos/krb5_interface_impl.cpp
create mode 100644 be/src/common/kerberos/krb5_interface_impl.h
copy be/src/exec/schema_scanner/{schema_backend_active_tasks.cpp =>
schema_backend_kerberos_ticket_cache.cpp} (53%)
copy be/src/exec/schema_scanner/{schema_routine_scanner.h =>
schema_backend_kerberos_ticket_cache.h} (78%)
create mode 100644 be/src/io/fs/hdfs/hdfs_mgr.cpp
create mode 100644 be/src/io/fs/hdfs/hdfs_mgr.h
create mode 100644 be/src/pipeline/exec/mock_operator.h
delete mode 100644 be/src/vec/exec/format/table/table_format_reader.cpp
create mode 100644 be/test/common/kerberos/kerberos_config_test.cpp
create mode 100644 be/test/common/kerberos/kerberos_ticket_cache_auth_test.cpp
create mode 100644 be/test/common/kerberos/kerberos_ticket_cache_test.cpp
create mode 100644 be/test/common/kerberos/kerberos_ticket_mgr_test.cpp
create mode 100644 be/test/io/fs/hdfs/hdfs_mgr_test.cpp
create mode 100644 be/test/pipeline/operator/assert_nums_rows_operator.cpp
create mode 100644 be/test/pipeline/operator/datagen_operator_test.cpp
copy be/{src/pipeline/exec/empty_set_operator.cpp =>
test/pipeline/operator/empty_set_operator_test.cpp} (65%)
create mode 100644 be/test/pipeline/operator/operator_helper.h
create mode 100644
fe/fe-common/src/main/java/org/apache/doris/common/security/authentication/PreExecutionAuthenticatorCache.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/ShowAnalyzeCommand.java
copy
fe/fe-core/src/main/java/org/apache/doris/{analysis/AlterRepositoryStmt.java =>
nereids/trees/plans/commands/alter/AlterRepositoryCommand.java} (72%)
copy
fe/fe-core/src/test/java/org/apache/doris/{analysis/IsNullPredicateTest.java =>
datasource/paimon/PaimonExternalCatalogTest.java} (59%)
create mode 100644
regression-test/data/correctness_p0/test_column_prune_in_hash_join.out
rename
regression-test/data/nereids_function_p0/array/{test_array_map<char,double>.csv
=> test_array_map_char_double.csv} (100%)
rename
regression-test/data/nereids_function_p0/array/{test_array_map<datetime,decimal<76,56>>.csv
=> test_array_map_datetime_decimal.csv} (100%)
rename
regression-test/data/nereids_function_p0/array/{test_array_map<ipv4,ipv6>.csv
=> test_array_map_ipv4_ipv6.csv} (100%)
rename
regression-test/data/nereids_function_p0/array/{test_array_map<largeInt,string>.csv
=> test_array_map_largeInt_string.csv} (100%)
copy
regression-test/data/{correctness/test_constant_push_down_through_outer_join.out
=> statistics/test_analyze_mv.out} (77%)
copy
regression-test/suites/{nereids_p0/ddl/repository/show_repositories_command.groovy
=> alter_p2/test_alter_repository_command.groovy} (73%)
copy
regression-test/suites/backup_restore/{test_backup_restore_partition.groovy =>
test_backup_restore_storage_policy.groovy} (50%)
copy regression-test/suites/{metrics_p0/test_delete_bitmap_metrics.groovy =>
compaction/test_compaction_update_big_delete_bitmap.groovy} (59%)
create mode 100644
regression-test/suites/correctness_p0/test_column_prune_in_hash_join.groovy
delete mode 100644
regression-test/suites/external_table_p2/es/test_external_catalog_es.groovy
delete mode 100644
regression-test/suites/external_table_p2/es/test_external_es.groovy
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
