This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a change to branch auto-pick-65903-branch-4.1
in repository https://gitbox.apache.org/repos/asf/doris.git
discard 43f6f39a01d [fix](cast) Handle DST fallback in timestamp cast
monotonicity (#65903)
add 6c8c1cafb24 [fix](bucket) Raise autobucket_min_buckets default from 1
to 3 (#63729) (#66064)
add 82f726e1f4b [fix](cloud) normalize SHOW PARTITIONS display for storage
and replica (#60871) (#66057)
add 4650234fd0e [fix](cloud) Align colocate proc output and tablet health
in cloud mode (#60944) (#66061)
add ad313ef70e2 [fix](parquet) Directly evaluate runtime filters in V2
reader (#66149)
add 19bfc0a228a [feature](paimon) Backport Paimon options and read/write
coverage (#66176)
add 18b9e152656 branch-4.1: [opt](scan) Boost scanner concurrency under
starvation (#66107)
add c64618c8131 branch-4.1: [Exec](shuffle) random shuffle firstly use
local channel to improve performance #59431 (#66103)
add 20b5c55eb15 branch-4.1: [opt](cloud) Add warm up job count metric on
BE (#66136)
add 57e556ff721 branch-4.1:[fix](filecache) Limit LRU recorder shadow
queue size(pick#64798) (#66132)
add 6d6143122f7 branch-4.1: [feature](fe) Add meta service RPC rate
limiting in FE (#65694) (#66140)
add 6fb81ea8331 branch-4.1: [fix](build) Let ScopedLSANDisabler compile
without a sanitizer #66049 (#66075)
add a6589bd9c6b branch-4.1: [chore](recycler) Disable
enable_mark_delete_rowset_before_recycle and
enable_abort_txn_and_job_for_delete_rowset_before_recycle for recycler- #66150
#66150 (#66229)
add 20635ab3036 branch-4.1: [feature](variant) Add native ColumnVariantV2
execution (#66188)
add 758aa0a7d81 [fix](pipeline) Add streaming aggregation local exchange
switch (#66216)
add c9e9629017b branch-4.1: [chore](deps) Upgrade vulnerable FE
dependencies #65700 (#66126)
add 4bc49a509b6 branch-4.1:[fix](regression) Adjust large TTL cache
regression case(pick#64789) (#66131)
add 4d3d5024789 branch-4.1: [fix](load) correct quorum participants for
incremental streams #66016 (#66171)
add 319d2f2b2c5 [fix](fe) Cancel rebuilt VCG warm up jobs on drop (#65426)
(#66168)
add 7d1dfd1426a branch-4.1: [opt](repeat) deduplicate grouping scalar
functions from projetion inrepeat #65880 (#66143)
add 9782738437f branch-4.1:[fix](fe) Improve MaxCompute catalog validation
(#64119) (#66157)
add 6ba1364db92 branch-4.1: [fix](cloud) Fix SchemaVariablesScanner crash
due to incomplete FE response #65994 (#66015)
add af27580b541 branch-4.1: [fix](cloud) Use bthread-aware shared mutex
for tablet header lock (#66020)
add 70bbb1c03d2 branch-4.1: [test](regression) Add external correctness P0
coverage #66002 (#66023)
add 94597a13361 [fix](regression) Skip mirrored CSV header in HTTP TVF
(#66027)
add 5d72ce4122b [fix](cloud) CloudUpgradeMgr inspect and abort failed
conflict txns while waiting (#60830) (#66055)
add 8794c7d5014 branch-4.1: [test](regression) Expand Iceberg write
evolution coverage #66021 (#66043)
add fb69297540f [fix](filecache) pass tablet_id through FileReaderOptions
instead of parsing from path (#61683) (#66062)
add e4fb2c4dc50 [fix](cloud) Exclude decommissioning BE from BE selection
(#65221) (#66076)
add 3c3f33d8f43 branch-4.1: [improvement](fe) add fe_meta_auth_token for
FE meta-service internal HTTP auth (#66090)
add 8281730915c [fix](cloud) Fix SchemaVariablesScanner crash due to
incomplete FE response (#65994) (#66190)
add fe65d35ade0 branch-4.1: [fix](regression) Initialize OceanBase test
data explicitly #66141 (#66155)
add 17644f91bc2 [branch-4.1][fix](regression) Match Parquet TIME scanner
errors (#65885)
add 67ea11c6c6b branch-4.1: [fix](variant) Recognize nullable array
elements as NestedGroup types #66196 (#66202)
add 41ff7643b28 branch-4.1: [fix](eager-agg) null-to-non-null safety check
and remove redundant normalize calls in eager aggregation (#66208)
add d02f448bba0 branch-4.1: [fix](cloud) Prevent urgent load from
preempting schema change lock #66082 (#66226)
add 64ba650e670 [opt](exec) optimize fixed key packing (#65572) (#66220)
add 139cd2c93c3 branch-4.1: [feature](paimon) Support table writes via JNI
and schema evolution (#65868)
add 59f8a9eef06 [fix](regression) Stabilize cloud docker regression cases
(#65258) (#66162)
add 645b3e8ec91 branch-4.1: [improve](cloud) Skip non-MOW tablets for
get_topn_tablet_delete_bitmap_score #65964 (#66257)
add 0e0ef7f468c branch-4.1: [fix](hive) invalidate stale file cache on
partition refresh when partition cache misses #65334 (#66259)
add 723c7ebf1db [branch-4.1][improvement](agg) Add a knob to control local
exchange before aggregation (#66104)
add e7e6a579965 branch-4.1: [fix](fe) Accept spaced TIMESTAMPTZ offsets in
range partition bounds (#66292)
add 6830db1271c branch-4.1: [fix](build) Restore LSan detection (#66275)
add 8d721c3bfb8 branch-4.1: [fix](be) Fix duplicate symbol
__lsan_ignore_object when build be ut in LSAN #64164 (#66274)
add 145882f147f branch-4.1: [chore](thirdparty) introduce thridparty about
lance-c #65304 (#66304)
add c1573718610 branch-4.1: [fix](lakehouse) Backport external write and
metadata consistency fixes (#66246)
add 818c08e39b0 [improvement](cloud) Use rendezvous hashing for colocate
tablet placement (#64638) (#66066)
add 5ea5dd73e13 [fix](replica) Resolve conflicting default replica
properties (#65836) (#66189)
add 9f5480e45a2 branch-4.1: [fix](cloud) Skip unnecessary update tablet to
ms when alter table property #65983 (#66256)
add 5bd0cef2564 [fix](cast) Handle DST fallback in timestamp cast
monotonicity (#65903)
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 (43f6f39a01d)
\
N -- N -- N refs/heads/auto-pick-65903-branch-4.1 (5bd0cef2564)
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/cmake/thirdparty.cmake | 4 +
be/src/agent/be_exec_version_manager.cpp | 4 +-
be/src/agent/be_exec_version_manager.h | 1 +
be/src/cloud/cloud_base_compaction.cpp | 2 +-
be/src/cloud/cloud_cumulative_compaction.cpp | 2 +-
be/src/cloud/cloud_full_compaction.cpp | 2 +-
be/src/cloud/cloud_internal_service.cpp | 28 +-
be/src/cloud/cloud_meta_mgr.cpp | 4 +-
be/src/cloud/cloud_meta_mgr.h | 2 +-
be/src/cloud/cloud_storage_engine.cpp | 10 +-
be/src/cloud/cloud_tablet.cpp | 53 +-
be/src/cloud/cloud_tablet.h | 16 +-
be/src/cloud/cloud_tablet_mgr.cpp | 2 +-
be/src/cloud/cloud_warm_up_manager.cpp | 38 +-
be/src/cloud/cloud_warm_up_manager.h | 3 +-
be/src/common/config.cpp | 5 +
be/src/common/config.h | 4 +
be/src/common/phdr_cache.cpp | 10 +-
be/src/core/arena.h | 18 +
be/src/core/column/column_variant.cpp | 3 +
.../core/column/variant_v2/column_variant_v2.cpp | 1382 ++++++++++
be/src/core/column/variant_v2/column_variant_v2.h | 277 ++
.../variant_v2/column_variant_v2_read_view.cpp | 102 +
.../variant_v2/column_variant_v2_typed_column.cpp | 47 +-
.../variant_v2/column_variant_v2_typed_column.h | 156 ++
be/src/core/data_type/data_type_factory.cpp | 38 +-
be/src/core/data_type/data_type_variant_v2.cpp | 101 +
be/src/core/data_type/data_type_variant_v2.h | 63 +
.../core/data_type_serde/data_type_array_serde.cpp | 46 +-
.../data_type_serde/data_type_datetimev2_serde.cpp | 65 +-
.../data_type_serde/data_type_datetimev2_serde.h | 5 +
.../data_type_serde/data_type_datev2_serde.cpp | 55 +-
.../core/data_type_serde/data_type_datev2_serde.h | 5 +
.../data_type_serde/data_type_decimal_serde.cpp | 94 +-
.../core/data_type_serde/data_type_decimal_serde.h | 27 +-
.../core/data_type_serde/data_type_map_serde.cpp | 64 +-
.../data_type_serde/data_type_nullable_serde.cpp | 36 +-
.../data_type_serde/data_type_nullable_serde.h | 2 +
.../data_type_serde/data_type_number_serde.cpp | 85 +-
.../core/data_type_serde/data_type_number_serde.h | 28 +
be/src/core/data_type_serde/data_type_serde.cpp | 11 +
be/src/core/data_type_serde/data_type_serde.h | 14 +
.../data_type_serde/data_type_struct_serde.cpp | 16 +-
.../core/data_type_serde/data_type_time_serde.cpp | 57 +
be/src/core/data_type_serde/data_type_time_serde.h | 5 +
.../data_type_timestamptz_serde.cpp | 64 +-
.../data_type_serde/data_type_timestamptz_serde.h | 5 +
.../data_type_serde/data_type_variant_v2_serde.cpp | 592 ++++
.../data_type_serde/data_type_variant_v2_serde.h | 73 +
be/src/core/data_type_serde/orc_serde_utils.h | 77 +
.../core/data_type_serde/parquet_decode_source.h | 13 +
.../core/value/variant/variant_batch_builder.cpp | 1780 ++++++++++++
be/src/core/value/variant/variant_batch_builder.h | 265 ++
be/src/core/value/variant/variant_canonical.cpp | 1168 ++++++++
be/src/core/value/variant/variant_canonical.h | 168 ++
be/src/core/value/variant/variant_field.cpp | 389 +++
be/src/core/value/variant/variant_field.h | 78 +
be/src/core/value/variant/variant_metadata.cpp | 172 ++
.../src/core/value/variant/variant_metadata.h | 42 +-
.../core/value/variant/variant_parquet_encoding.h | 123 +
be/src/core/value/variant/variant_scalar.cpp | 353 +++
be/src/core/value/variant/variant_scalar.h | 73 +
be/src/core/value/variant/variant_value.cpp | 482 ++++
be/src/core/value/variant/variant_value.h | 79 +
be/src/exec/common/hash_table/hash_key_type.h | 7 +-
be/src/exec/common/hash_table/hash_map_context.h | 9 +-
.../exec/exchange/local_exchange_source_operator.h | 5 +
be/src/exec/operator/aggregation_sink_operator.h | 5 +-
.../distinct_streaming_aggregation_operator.h | 4 +-
be/src/exec/operator/exchange_sink_operator.cpp | 12 +
be/src/exec/operator/exchange_sink_operator.h | 1 +
be/src/exec/operator/operator.cpp | 20 +
be/src/exec/operator/operator.h | 3 +
.../exec/operator/paimon_table_sink_operator.cpp | 39 +
be/src/exec/operator/paimon_table_sink_operator.h | 104 +
.../exec/operator/streaming_aggregation_operator.h | 5 +-
be/src/exec/pipeline/pipeline.cpp | 10 +-
be/src/exec/pipeline/pipeline_fragment_context.cpp | 23 +
be/src/exec/scan/scanner_context.cpp | 28 +-
be/src/exec/scan/scanner_context.h | 3 +-
be/src/exec/scan/scanner_scheduler.cpp | 2 +-
be/src/exec/sink/load_stream_stub.h | 2 +
be/src/exec/sink/viceberg_delete_sink.cpp | 53 +-
be/src/exec/sink/viceberg_delete_sink.h | 8 +
be/src/exec/sink/viceberg_merge_sink.cpp | 142 +-
be/src/exec/sink/viceberg_merge_sink.h | 7 +
.../sink/writer/iceberg/partition_transformers.h | 5 +-
.../writer/iceberg/viceberg_delete_file_writer.h | 2 +
.../writer/iceberg/viceberg_partition_writer.cpp | 31 +-
.../writer/iceberg/viceberg_partition_writer.h | 9 +-
.../sink/writer/iceberg/viceberg_table_writer.cpp | 33 +-
.../sink/writer/iceberg/viceberg_table_writer.h | 12 +
.../writer/paimon/ffi_paimon_write_backend.cpp | 24 +-
.../sink/writer/paimon/ffi_paimon_write_backend.h | 31 +-
.../writer/paimon/jni_paimon_write_backend.cpp | 487 ++++
.../sink/writer/paimon/jni_paimon_write_backend.h | 107 +
.../writer/paimon/paimon_jni_memory_manager.cpp | 304 ++
.../sink/writer/paimon/paimon_jni_memory_manager.h | 81 +
.../sink/writer/paimon/paimon_table_writer.cpp | 163 ++
.../exec/sink/writer/paimon/paimon_table_writer.h | 102 +
.../exec/sink/writer/paimon/paimon_write_backend.h | 108 +
.../writer/paimon/paimon_write_backend_factory.cpp | 44 +
be/src/exec/sink/writer/vtablet_writer_v2.cpp | 24 +-
be/src/exprs/aggregate/aggregate_function_uniq.cpp | 16 +
be/src/exprs/aggregate/aggregate_function_uniq.h | 92 +
be/src/exprs/bloom_filter_func.h | 23 +
be/src/exprs/create_predicate_function.h | 1 +
be/src/exprs/function/cast/function_cast.cpp | 45 +-
.../cast/variant_v2/cast_array_to_variant.cpp | 235 ++
.../cast/variant_v2/cast_variant_to_array.cpp | 153 +
.../cast/variant_v2/cast_variant_to_jsonb.cpp | 106 +
.../cast/variant_v2/cast_variant_to_scalar.cpp | 520 ++++
.../cast/variant_v2/cast_variant_to_string.cpp | 246 ++
.../function/cast/variant_v2/cast_variant_v2.cpp | 205 ++
.../function/cast/variant_v2/cast_variant_v2.h | 19 +-
.../cast/variant_v2/cast_variant_v2_internal.h | 77 +
be/src/exprs/function/function_struct.cpp | 7 +-
be/src/exprs/function/function_variant_element.cpp | 94 +-
.../exprs/function/function_variant_element_v2.cpp | 365 +++
.../exprs/function/function_variant_element_v2.h | 95 +
be/src/exprs/function/function_variant_parse.cpp | 194 ++
be/src/exprs/function/function_variant_type.cpp | 18 +-
.../exprs/function/parse/variant_jsonb_parse.cpp | 558 ++++
be/src/exprs/function/parse/variant_jsonb_parse.h | 69 +
.../exprs/function/parse/variant_string_parse.cpp | 497 ++++
be/src/exprs/function/parse/variant_string_parse.h | 404 +++
be/src/exprs/function/simple_function_factory.h | 2 +
be/src/exprs/hybrid_set.h | 31 +
be/src/exprs/runtime_filter_expr.cpp | 34 +
be/src/exprs/runtime_filter_expr.h | 6 +
be/src/exprs/table_function/vexplode_v2.cpp | 80 +-
be/src/exprs/table_function/vexplode_v2.h | 3 +
be/src/exprs/vbloom_predicate.cpp | 20 +
be/src/exprs/vbloom_predicate.h | 5 +
be/src/exprs/vcase_expr.h | 16 +-
be/src/exprs/vcompound_pred.h | 103 +
be/src/exprs/vcondition_expr.cpp | 1 +
be/src/exprs/vdirect_in_predicate.h | 29 +
be/src/exprs/vectorized_fn_call.cpp | 180 +-
be/src/exprs/vectorized_fn_call.h | 9 +
be/src/exprs/vexpr.h | 53 +-
be/src/exprs/vin_predicate.cpp | 112 +
be/src/exprs/vin_predicate.h | 13 +
be/src/exprs/vtopn_pred.cpp | 275 ++
be/src/exprs/vtopn_pred.h | 41 +
be/src/format/table/paimon_jni_reader.cpp | 4 +-
be/src/format_v2/jni/paimon_jni_reader.cpp | 4 +-
be/src/format_v2/parquet/parquet_profile.cpp | 16 +
be/src/format_v2/parquet/parquet_profile.h | 11 +
be/src/format_v2/parquet/parquet_scan.cpp | 169 +-
be/src/format_v2/parquet/reader/column_reader.cpp | 22 +-
be/src/format_v2/parquet/reader/column_reader.h | 14 +-
.../format_v2/parquet/reader/direct_predicate.h | 20 +-
.../parquet/reader/native/column_chunk_reader.cpp | 293 +-
.../parquet/reader/native/column_chunk_reader.h | 51 +-
.../parquet/reader/native/column_reader.cpp | 161 +-
.../parquet/reader/native/column_reader.h | 13 +-
.../parquet/reader/native_column_reader.cpp | 113 +-
.../parquet/reader/native_column_reader.h | 10 +-
be/src/format_v2/table_reader.h | 206 +-
.../schema_variables_scanner.cpp | 9 +
be/src/io/cache/block_file_cache.cpp | 43 +
be/src/io/cache/block_file_cache.h | 2 +
be/src/io/cache/block_file_cache_downloader.cpp | 2 +
be/src/io/cache/block_file_cache_downloader.h | 1 +
be/src/io/cache/cached_remote_file_reader.cpp | 58 +-
be/src/io/cache/cached_remote_file_reader.h | 3 +-
be/src/io/cache/file_cache_common.h | 2 +
be/src/io/cache/lru_queue_recorder.cpp | 121 +-
be/src/io/cache/lru_queue_recorder.h | 4 +
be/src/io/tools/file_cache_microbench.cpp | 1 +
be/src/runtime/runtime_state.h | 19 +
.../storage/compaction/collection_statistics.cpp | 2 +-
be/src/storage/compaction/compaction.cpp | 8 +-
.../cumulative_compaction_time_series_policy.cpp | 5 +-
be/src/storage/compaction/full_compaction.cpp | 2 +-
be/src/storage/index/index_file_reader.cpp | 10 +-
be/src/storage/index/index_file_reader.h | 7 +-
be/src/storage/index/index_file_writer.cpp | 10 +-
be/src/storage/index/index_file_writer.h | 4 +-
.../index/inverted/inverted_index_fs_directory.cpp | 4 +-
.../index/inverted/inverted_index_fs_directory.h | 3 +-
be/src/storage/rowset/beta_rowset.cpp | 4 +-
be/src/storage/rowset/beta_rowset_writer.cpp | 3 +-
be/src/storage/rowset/rowset_writer.h | 2 +-
be/src/storage/rowset_builder.cpp | 2 +-
be/src/storage/schema_change/schema_change.cpp | 4 +-
be/src/storage/segment/segment.cpp | 11 +-
be/src/storage/segment/segment.h | 1 +
be/src/storage/tablet/base_tablet.cpp | 4 +
be/src/storage/tablet/base_tablet.h | 9 +-
be/src/storage/tablet/tablet.cpp | 63 +-
be/src/storage/tablet/tablet.h | 9 +-
be/src/storage/tablet/tablet_manager.cpp | 2 +-
be/src/storage/task/engine_clone_task.cpp | 2 +-
be/src/storage/task/index_builder.cpp | 14 +-
be/src/util/bthread_shared_mutex.h | 125 +
be/src/util/debug/leak_annotations.h | 34 +-
.../cloud/cloud_empty_rowset_compaction_test.cpp | 2 +-
be/test/cloud/cloud_meta_mgr_test.cpp | 28 +-
be/test/cloud/cloud_tablet_test.cpp | 2 +-
be/test/core/column/column_variant_test.cpp | 8 +
be/test/core/column/column_variant_v2_test.cpp | 2911 ++++++++++++++++++++
.../data_type_serde_parquet_test.cpp | 137 +
...type_variant_v2_serde_binary_roundtrip_test.cpp | 526 ++++
.../data_type_variant_v2_serde_input_test.cpp | 310 +++
.../data_type_variant_v2_serde_jsonb_test.cpp | 246 ++
.../data_type_variant_v2_serde_output_test.cpp | 382 +++
be/test/exec/operator/agg_operator_test.cpp | 65 +
...istinct_streaming_aggregation_operator_test.cpp | 15 +
.../exec/operator/streaming_agg_operator_test.cpp | 14 +
be/test/exec/scan/scanner_context_test.cpp | 25 +
be/test/exec/sink/viceberg_merge_sink_test.cpp | 275 +-
be/test/exec/sink/vtablet_writer_v2_test.cpp | 28 +
.../writer/iceberg/partition_transformers_test.cpp | 26 +
.../writer/paimon/paimon_write_backend_test.cpp | 15 +-
be/test/exec/sort/merge_sorter_state.cpp | 24 +-
.../aggregate_function_uniq_variant_test.cpp | 272 ++
.../cast/cast_variant_v2_benchmark_test.cpp | 227 ++
.../function/cast/cast_variant_v2_from_test.cpp | 522 ++++
.../function/cast/cast_variant_v2_to_test.cpp | 317 +++
.../function_variant_element_v2_encoded_test.cpp | 239 ++
.../function_variant_element_v2_string_test.cpp | 50 +
.../exprs/function/function_variant_parse_test.cpp | 387 +++
.../test/exprs/variant_v2_execution_test.cpp | 27 +-
.../format/transformer/vorc_transformer_test.cpp | 205 ++
be/test/format_v2/parquet/native_decoder_test.cpp | 48 +-
be/test/format_v2/parquet/parquet_scan_test.cpp | 1352 ++++++++-
be/test/format_v2/table/paimon_reader_test.cpp | 18 +-
be/test/format_v2/table_reader_test.cpp | 592 ++++
be/test/io/cache/block_file_cache_test.cpp | 12 +
.../io/cache/block_file_cache_test_lru_dump.cpp | 1 +
.../io/cache/block_file_cache_test_meta_store.cpp | 14 +-
be/test/io/cache/cache_lru_dumper_test.cpp | 106 +
be/test/io/fs/packed_file_concurrency_test.cpp | 2 +
be/test/runtime/runtime_predicate_test.cpp | 229 +-
be/test/util/bthread_shared_mutex_test.cpp | 264 ++
.../variant/testdata/ParquetVariantGolden.java | 1229 +++++++++
.../testdata/doris_java_verified_vectors.tsv | 66 +
.../util/variant/testdata/parquet_java_vectors.tsv | 86 +
.../util/variant/variant_batch_builder_test.cpp | 1941 +++++++++++++
be/test/util/variant/variant_canonical_test.cpp | 910 ++++++
be/test/util/variant/variant_field_test.cpp | 580 ++++
.../util/variant/variant_golden_vector_test.cpp | 753 +++++
be/test/util/variant/variant_jsonb_parse_test.cpp | 998 +++++++
be/test/util/variant/variant_string_parse_test.cpp | 697 +++++
be/test/util/variant/variant_test_utils.cpp | 329 +++
be/test/util/variant/variant_test_utils.h | 49 +
be/test/util/variant/variant_value_test.cpp | 488 ++++
build.sh | 4 +-
cloud/src/common/config.h | 4 +-
cloud/src/meta-service/meta_service.cpp | 8 +-
cloud/test/meta_service_job_test.cpp | 30 +
cloud/test/meta_service_test.cpp | 118 +-
dist/LICENSE-dist.txt | 3 +
dist/licenses/LICENSE-lance-c-rust-crates.txt | 625 +++++
.../docker-compose/oceanbase/oceanbase.yaml.tpl | 29 +-
.../{paimon-scanner => paimon-connector}/pom.xml | 9 +-
.../doris/paimon/DorisMemorySegmentPool.java | 57 +
.../apache/doris/paimon/GlobalIndexAssigner.java | 177 ++
.../apache/doris/paimon/PaimonArrowConverter.java | 409 +++
.../org/apache/doris/paimon/PaimonColumnValue.java | 7 +-
.../org/apache/doris/paimon/PaimonCommitCodec.java | 184 ++
.../apache/doris/paimon/PaimonJdbcDriverUtils.java | 0
.../org/apache/doris/paimon/PaimonJniScanner.java | 18 +-
.../org/apache/doris/paimon/PaimonJniWriter.java | 660 +++++
.../org/apache/doris/paimon/PaimonTypeUtils.java | 0
.../java/org/apache/doris/paimon/PaimonUtils.java | 0
.../org/apache/doris/paimon/PaimonWriteSchema.java | 131 +
.../src/main/resources/package.xml | 0
.../doris/paimon/GlobalIndexAssignerTest.java} | 32 +-
.../doris/paimon/PaimonArrowConverterTest.java | 119 +
.../apache/doris/paimon/PaimonColumnValueTest.java | 89 +
.../apache/doris/paimon/PaimonCommitCodecTest.java | 110 +
.../doris/paimon/PaimonJdbcDriverUtilsTest.java | 0
.../apache/doris/paimon/PaimonJniScannerTest.java | 0
.../apache/doris/paimon/PaimonJniWriterTest.java | 101 +
.../apache/doris/paimon/PaimonWriteSchemaTest.java | 200 ++
fe/be-java-extensions/pom.xml | 2 +-
.../main/java/org/apache/doris/catalog/Type.java | 38 +-
.../java/org/apache/doris/catalog/VariantType.java | 34 +-
.../main/java/org/apache/doris/common/Config.java | 59 +-
.../java/org/apache/doris/common/ConfigBase.java | 20 +-
.../MetaServiceRpcRateLimitConfigValidator.java | 103 +
.../java/org/apache/doris/common/ConfigTest.java | 58 +
fe/fe-core/pom.xml | 6 +-
.../main/java/org/apache/doris/alter/Alter.java | 4 +
.../org/apache/doris/analysis/TableScanParams.java | 47 +-
.../doris/catalog/BuiltinScalarFunctions.java | 4 +
.../apache/doris/catalog/ColocateTableIndex.java | 22 +-
.../doris/catalog/InternalSchemaInitializer.java | 8 +-
.../org/apache/doris/catalog/PartitionKey.java | 20 +-
.../java/org/apache/doris/catalog/Replica.java | 21 +
.../org/apache/doris/catalog/TableProperty.java | 28 +-
.../doris/clone/DynamicPartitionScheduler.java | 69 +-
.../cloud/alter/CloudSchemaChangeHandler.java | 13 +-
.../cloud/catalog/CloudColocatePlacement.java | 64 +
.../cloud/catalog/CloudInstanceStatusChecker.java | 11 +-
.../apache/doris/cloud/catalog/CloudReplica.java | 132 +-
.../doris/cloud/catalog/CloudUpgradeMgr.java | 42 +
.../apache/doris/cloud/rpc/MetaServiceProxy.java | 97 +-
.../rpc/MetaServiceRateLimitException.java} | 10 +-
.../doris/cloud/rpc/MetaServiceRpcRateLimiter.java | 278 ++
.../doris/cloud/system/CloudSystemInfoService.java | 149 +-
.../proc/ColocationGroupBackendSeqsProcNode.java | 24 +-
.../doris/common/proc/ColocationGroupProcDir.java | 158 +-
.../doris/common/proc/IndexSchemaProcNode.java | 4 +-
.../doris/common/proc/PartitionsProcDir.java | 17 +-
.../doris/common/proc/TabletHealthProcDir.java | 7 +-
.../doris/common/profile/SummaryProfile.java | 44 +-
.../doris/common/util/DynamicPartitionUtil.java | 29 +-
.../org/apache/doris/common/util/HttpURLUtil.java | 15 +
.../apache/doris/common/util/PropertyAnalyzer.java | 88 +-
.../org/apache/doris/common/util/TimeUtils.java | 19 +
.../org/apache/doris/datasource/ExternalTable.java | 10 +-
.../apache/doris/datasource/FileQueryScanNode.java | 77 +-
.../org/apache/doris/datasource/FileScanNode.java | 22 +-
.../doris/datasource/hive/HMSExternalTable.java | 39 +-
.../datasource/hive/HiveExternalMetaCache.java | 46 +-
.../doris/datasource/hudi/HudiMvccSnapshot.java | 9 +-
.../apache/doris/datasource/hudi/HudiUtils.java | 42 +-
.../doris/datasource/hudi/source/HudiScanNode.java | 32 +-
.../iceberg/IcebergExternalMetaCache.java | 10 +-
.../datasource/iceberg/IcebergExternalTable.java | 21 +-
.../datasource/iceberg/IcebergMvccSnapshot.java | 15 +
.../iceberg/IcebergSnapshotCacheValue.java | 165 +-
.../iceberg/IcebergSysExternalTable.java | 19 +
.../datasource/iceberg/IcebergTransaction.java | 70 +-
.../doris/datasource/iceberg/IcebergUtils.java | 41 +-
.../iceberg/rewrite/RewriteDataFileExecutor.java | 21 +-
.../iceberg/rewrite/RewriteGroupTask.java | 23 +
.../datasource/iceberg/source/IcebergScanNode.java | 154 +-
.../doris/datasource/maxcompute/MCTransaction.java | 4 +
.../maxcompute/MaxComputeExternalCatalog.java | 70 +-
.../maxcompute/MaxComputeExternalTable.java | 11 +
.../maxcompute/source/MaxComputeScanNode.java | 5 +
.../PaimonLatestSnapshotProjectionLoader.java | 16 +-
.../paimon/PaimonPartitionInfoLoader.java | 22 +-
.../doris/datasource/mvcc/EmptyMvccSnapshot.java | 4 +
.../apache/doris/datasource/mvcc/MvccSnapshot.java | 8 +
.../paimon/DorisToPaimonTypeVisitor.java | 6 +
.../datasource/paimon/PaimonExternalCatalog.java | 18 +-
.../datasource/paimon/PaimonExternalMetaCache.java | 2 +-
.../datasource/paimon/PaimonExternalTable.java | 135 +-
.../doris/datasource/paimon/PaimonMetadataOps.java | 310 ++-
.../datasource/paimon/PaimonMvccSnapshot.java | 10 +
.../datasource/paimon/PaimonPartitionInfo.java | 37 +-
.../doris/datasource/paimon/PaimonScanParams.java | 391 +++
.../paimon/PaimonSnapshotCacheValue.java | 11 +
.../datasource/paimon/PaimonSysExternalTable.java | 24 +
.../doris/datasource/paimon/PaimonTransaction.java | 460 ++++
.../apache/doris/datasource/paimon/PaimonUtil.java | 201 +-
.../datasource/paimon/PaimonWriteBinding.java | 231 ++
.../doris/datasource/paimon/PaimonWriteTarget.java | 129 +
.../datasource/paimon/source/PaimonScanNode.java | 169 +-
.../datasource/paimon/source/PaimonSource.java | 32 +-
.../metastore/AbstractPaimonProperties.java | 109 +-
.../org/apache/doris/httpv2/meta/MetaService.java | 77 +-
.../doris/httpv2/rest/manager/NodeAction.java | 13 +-
.../java/org/apache/doris/master/MetaHelper.java | 2 +-
.../java/org/apache/doris/metric/CloudMetrics.java | 17 +
.../doris/mtmv/MTMVPartitionExprDateTrunc.java | 21 +-
.../org/apache/doris/mtmv/MTMVPartitionUtil.java | 38 +-
.../doris/nereids/ExternalTablePreloadInfo.java | 3 +-
.../org/apache/doris/nereids/StatementContext.java | 35 +-
.../nereids/analyzer/UnboundIcebergTableSink.java | 38 +-
...gTableSink.java => UnboundPaimonTableSink.java} | 88 +-
.../doris/nereids/analyzer/UnboundRelation.java | 8 +-
.../nereids/analyzer/UnboundTableSinkCreator.java | 24 +
.../glue/translator/PhysicalPlanTranslator.java | 38 +-
.../doris/nereids/parser/LogicalPlanBuilder.java | 14 +-
.../nereids/properties/RequestPropertyDeriver.java | 13 +-
.../org/apache/doris/nereids/rules/RuleSet.java | 2 +
.../org/apache/doris/nereids/rules/RuleType.java | 2 +
.../doris/nereids/rules/analysis/BindRelation.java | 72 +-
.../doris/nereids/rules/analysis/BindSink.java | 170 +-
.../nereids/rules/analysis/CheckAfterRewrite.java | 17 +-
.../nereids/rules/analysis/CheckAnalysis.java | 23 +
.../nereids/rules/analysis/ExpressionAnalyzer.java | 7 +
.../nereids/rules/analysis/NormalizeRepeat.java | 34 +-
.../exploration/mv/MaterializedViewUtils.java | 9 +-
.../nereids/rules/expression/check/CheckCast.java | 11 +-
.../expression/rules/FoldConstantRuleOnBE.java | 8 +-
.../LogicalFileScanToPhysicalFileScan.java | 3 +-
.../LogicalHudiScanToPhysicalHudiScan.java | 3 +-
...ebergDeleteSinkToPhysicalIcebergDeleteSink.java | 1 +
...IcebergMergeSinkToPhysicalIcebergMergeSink.java | 2 +
...IcebergTableSinkToPhysicalIcebergTableSink.java | 1 +
...lPaimonTableSinkToPhysicalPaimonTableSink.java} | 18 +-
.../rules/rewrite/PruneFileScanPartition.java | 14 +-
.../rewrite/eageraggregation/EagerAggRewriter.java | 7 +-
.../eageraggregation/PushDownAggregation.java | 7 +-
.../doris/nereids/trees/expressions/CaseWhen.java | 2 +-
.../doris/nereids/trees/expressions/Cast.java | 22 +-
.../doris/nereids/trees/expressions/IsNull.java | 2 +-
.../nereids/trees/expressions/NullSafeEqual.java | 2 +-
.../trees/expressions/NullToNonNullFunction.java | 57 +
.../doris/nereids/trees/expressions/TryCast.java | 6 +
.../functions/ExplicitlyCastableSignature.java | 7 +
.../trees/expressions/functions/agg/Count.java | 13 +-
.../functions/agg/MultiDistinctCount.java | 2 +-
.../expressions/functions/scalar/Coalesce.java | 3 +-
.../functions/scalar/CreateNamedStruct.java | 4 +-
.../expressions/functions/scalar/ElementAt.java | 22 +-
.../trees/expressions/functions/scalar/If.java | 3 +-
.../functions/scalar/Ipv4StringToNumOrDefault.java | 3 +-
.../functions/scalar/Ipv6StringToNumOrDefault.java | 3 +-
.../expressions/functions/scalar/NonNullable.java | 4 +-
.../functions/scalar/NotNullOrEmpty.java | 3 +-
.../expressions/functions/scalar/NullOrEmpty.java | 3 +-
.../trees/expressions/functions/scalar/Nvl.java | 3 +-
.../{NotNullOrEmpty.java => ParseToVariant.java} | 46 +-
.../functions/scalar/ToIpv4OrDefault.java | 3 +-
.../functions/scalar/ToIpv6OrDefault.java | 3 +-
.../{NullOrEmpty.java => TryParseToVariant.java} | 46 +-
.../expressions/literal/StringLikeLiteral.java | 12 +-
.../trees/expressions/literal/StructLiteral.java | 14 +-
.../expressions/literal/TimestampTzLiteral.java | 162 +-
.../apache/doris/nereids/trees/plans/PlanType.java | 3 +
.../doris/nereids/trees/plans/algebra/Repeat.java | 2 +-
.../trees/plans/commands/CreateTableCommand.java | 35 +-
.../trees/plans/commands/ExecuteCommand.java | 25 +
.../trees/plans/commands/IcebergDeleteCommand.java | 14 +-
.../trees/plans/commands/IcebergMergeCommand.java | 25 +-
.../trees/plans/commands/IcebergUpdateCommand.java | 21 +-
.../commands/info/ModifyTablePropertiesOp.java | 2 +
.../commands/insert/IcebergDeleteExecutor.java | 7 +-
.../commands/insert/IcebergInsertExecutor.java | 7 +-
.../commands/insert/IcebergMergeExecutor.java | 6 +-
.../commands/insert/InsertIntoTableCommand.java | 18 +-
.../insert/InsertOverwriteTableCommand.java | 26 +-
.../trees/plans/commands/insert/InsertUtils.java | 22 +-
.../insert/PaimonInsertCommandContext.java | 57 +
.../commands/insert/PaimonInsertExecutor.java | 60 +
.../trees/plans/logical/LogicalFileScan.java | 140 +-
.../trees/plans/logical/LogicalHudiScan.java | 67 +-
.../plans/logical/LogicalIcebergDeleteSink.java | 22 +-
.../plans/logical/LogicalIcebergMergeSink.java | 46 +-
.../plans/logical/LogicalIcebergTableSink.java | 25 +-
...gTableSink.java => LogicalPaimonTableSink.java} | 75 +-
.../trees/plans/logical/LogicalSetOperation.java | 6 +-
.../trees/plans/physical/PhysicalFileScan.java | 65 +-
.../trees/plans/physical/PhysicalHudiScan.java | 34 +-
.../plans/physical/PhysicalIcebergDeleteSink.java | 35 +-
.../plans/physical/PhysicalIcebergMergeSink.java | 91 +-
.../plans/physical/PhysicalIcebergTableSink.java | 47 +-
.../physical/PhysicalLazyMaterializeFileScan.java | 2 +-
.../plans/physical/PhysicalPaimonTableSink.java | 179 ++
.../nereids/trees/plans/visitor/SinkVisitor.java | 15 +
.../org/apache/doris/nereids/types/DataType.java | 3 +-
.../apache/doris/nereids/types/VariantType.java | 93 +-
.../apache/doris/nereids/util/ExpressionUtils.java | 4 +-
.../doris/nereids/util/TypeCoercionUtils.java | 90 +-
.../apache/doris/planner/IcebergDeleteSink.java | 11 +-
.../org/apache/doris/planner/IcebergMergeSink.java | 19 +-
.../org/apache/doris/planner/IcebergTableSink.java | 25 +-
.../org/apache/doris/planner/PaimonTableSink.java | 155 ++
.../main/java/org/apache/doris/qe/Coordinator.java | 13 +-
.../org/apache/doris/qe/CoordinatorContext.java | 7 +-
.../org/apache/doris/qe/PointQueryExecutor.java | 8 +-
.../java/org/apache/doris/qe/SessionVariable.java | 28 +-
.../org/apache/doris/qe/runtime/LoadProcessor.java | 6 +
.../org/apache/doris/system/SystemInfoService.java | 4 +
.../doris/tablefunction/MetadataGenerator.java | 10 +-
.../AbstractExternalTransactionManager.java | 4 +-
.../doris/transaction/HiveTransactionManager.java | 2 +-
.../transaction/IcebergTransactionManager.java | 2 +-
.../doris/transaction/MCTransactionManager.java | 2 +-
...nManager.java => PaimonTransactionManager.java} | 16 +-
.../transaction/TransactionManagerFactory.java | 5 +
.../apache/doris/transaction/TransactionType.java | 3 +-
.../doris/alter/InternalSchemaAlterTest.java | 5 +
.../doris/analysis/PartitionExprUtilTest.java | 44 +
.../apache/doris/catalog/CreateTableLikeTest.java | 157 ++
.../doris/catalog/DynamicPartitionTableTest.java | 1767 +++++++++++-
.../org/apache/doris/catalog/PartitionKeyTest.java | 158 ++
.../apache/doris/catalog/TablePropertyTest.java | 113 +
.../java/org/apache/doris/catalog/TypeTest.java | 16 +
.../cloud/catalog/CloudColocatePlacementTest.java | 232 ++
.../catalog/CloudInstanceStatusCheckerTest.java | 115 +-
.../doris/cloud/catalog/CloudUpgradeMgrTest.java | 221 ++
.../doris/cloud/rpc/MetaServiceProxyTest.java | 190 ++
.../cloud/rpc/MetaServiceRpcRateLimiterTest.java | 275 ++
.../apache/doris/common/PropertyAnalyzerTest.java | 38 +
.../common/proc/CloudProcVersionDisplayTest.java | 16 +-
.../common/proc/ColocationGroupProcDirTest.java | 294 ++
.../doris/common/proc/IndexSchemaProcNodeTest.java | 40 +
.../doris/common/proc/PartitionsProcDirTest.java | 61 +
.../doris/common/proc/TabletHealthProcDirTest.java | 110 +
.../doris/common/profile/SummaryProfileTest.java | 30 +
.../apache/doris/common/util/HttpURLUtilTest.java | 93 +
.../apache/doris/common/util/TimeUtilsTest.java | 31 +
.../doris/datasource/FileQueryScanNodeTest.java | 67 +
.../datasource/hive/HiveMetaStoreCacheTest.java | 64 +
.../doris/datasource/hudi/HudiUtilsTest.java | 84 +
.../iceberg/IcebergDDLAndDMLPlanTest.java | 173 +-
.../iceberg/IcebergSysExternalTableTest.java | 48 +
.../datasource/iceberg/IcebergTransactionTest.java | 159 +-
.../doris/datasource/iceberg/IcebergUtilsTest.java | 107 +
.../rewrite/RewriteDataFileExecutorTest.java | 50 +
.../iceberg/source/IcebergScanNodeTest.java | 357 +++
.../datasource/maxcompute/MCTransactionTest.java | 54 +
.../maxcompute/MaxComputeExternalCatalogTest.java | 146 +
.../maxcompute/source/MaxComputeScanNodeTest.java | 79 +
.../paimon/PaimonExternalMetaCacheTest.java | 42 +-
.../datasource/paimon/PaimonExternalTableTest.java | 126 +
.../datasource/paimon/PaimonMetadataOpsTest.java | 82 +-
.../datasource/paimon/PaimonScanParamsTest.java | 355 +++
.../datasource/paimon/PaimonTransactionTest.java | 197 ++
.../doris/datasource/paimon/PaimonUtilTest.java | 303 +-
.../datasource/paimon/PaimonWriteBindingTest.java | 151 +
.../datasource/paimon/PaimonWriteTargetTest.java | 64 +
.../paimon/source/PaimonScanNodeTest.java | 562 +++-
.../datasource/paimon/source/PaimonSourceTest.java | 68 +
.../metastore/AbstractPaimonPropertiesTest.java | 111 +
.../apache/doris/external/hms/HmsCatalogTest.java | 26 +
.../apache/doris/httpv2/meta/MetaServiceTest.java | 295 ++
.../apache/doris/mtmv/MTMVPartitionUtilTest.java | 15 +
.../apache/doris/nereids/StatementContextTest.java | 189 +-
.../analyzer/UnboundIcebergTableSinkTest.java | 49 +
.../doris/nereids/parser/NereidsParserTest.java | 117 +
.../parser/ParseInsertPartitionSpecTest.java | 14 +
.../nereids/rules/analysis/BindRelationTest.java | 22 +
.../rules/analysis/FunctionRegistryTest.java | 74 +
.../rules/analysis/NormalizeRepeatTest.java | 30 +
.../rules/analysis/VariantEqualityContextTest.java | 119 +
.../exploration/mv/MaterializedViewUtilsTest.java | 19 +
.../rules/expression/check/CheckCastTest.java | 20 +
.../rewrite/PhysicalStorageLayerAggregateTest.java | 2 +-
.../rules/rewrite/PruneFileScanPartitionTest.java | 48 +
.../doris/nereids/trees/expressions/CastTest.java | 30 +
.../trees/expressions/functions/agg/CountTest.java | 56 +-
.../functions/scalar/ElementAtTest.java | 35 +-
.../expressions/literal/StringLikeLiteralTest.java | 41 +
.../expressions/literal/StructLiteralTest.java | 68 +
.../literal/TimestampTzLiteralTest.java | 122 +
.../plans/commands/CreateTableCommandTest.java | 133 +
.../trees/plans/commands/ExecuteCommandTest.java | 99 +
.../commands/insert/IcebergDeleteExecutorTest.java | 9 +-
.../commands/insert/IcebergMergeExecutorTest.java | 9 +-
.../plans/commands/insert/InsertUtilsTest.java | 71 +-
.../trees/plans/logical/LogicalFileScanTest.java | 197 +-
.../physical/PhysicalPaimonTableSinkTest.java | 63 +
.../apache/doris/nereids/types/DataTypeTest.java | 8 +
.../doris/nereids/util/TypeCoercionUtilsTest.java | 175 ++
.../doris/planner/IcebergDeleteSinkTest.java | 8 +-
.../apache/doris/planner/IcebergMergeSinkTest.java | 18 +-
.../apache/doris/planner/IcebergTableSinkTest.java | 120 +
.../org/apache/doris/qe/HmsQueryCacheTest.java | 13 +
.../java/org/apache/doris/qe/VariableMgrTest.java | 12 +
fe/pom.xml | 13 +-
gensrc/proto/data.proto | 1 +
gensrc/proto/types.proto | 1 +
gensrc/thrift/DataSinks.thrift | 28 +
gensrc/thrift/FrontendService.thrift | 2 +
gensrc/thrift/PaloInternalService.thrift | 1 +
gensrc/thrift/Types.thrift | 2 +
.../test_cloud_colocate_consistent_hash_join.out} | 6 +-
...est_timestamptz_partition_boundary_timezone.out | 26 +
.../iceberg_branch_tag_schema_change_extended.out | 1 -
.../iceberg/iceberg_branch_tag_operate.out | 1 -
.../iceberg/iceberg_query_tag_branch.out | 133 +-
.../iceberg_schema_change_ddl_with_branch.out | 1 -
.../test_iceberg_schema_dual_relation_matrix.out | 35 +
.../test_iceberg_schema_ref_actions_matrix.out | 43 +
.../test_iceberg_schema_time_travel_matrix.out | 6 +
.../iceberg/test_iceberg_sys_table.out | 17 +-
...eberg_write_merge_duplicate_source_negative.out | 2 +
.../paimon/paimon_data_system_table.out | 10 +-
.../external_table_p0/paimon/paimon_incr_read.out | 40 +
.../paimon/paimon_schema_change_ddl.out | 125 +
.../paimon/paimon_system_table.out | 9 +
.../paimon/paimon_time_travel.out | 6 +
.../paimon/test_paimon_merge_engine_matrix.out | 105 +
.../paimon/test_paimon_partition_table.out | 19 +-
...test_paimon_schema_branch_partition_matrix.out} | 5 +-
.../test_paimon_schema_dual_relation_matrix.out | 29 +
.../test_paimon_schema_time_travel_matrix.out | 27 +
.../paimon/test_paimon_write_boundary.out | 19 +
.../paimon/test_paimon_hms_catalog_write.out | 13 +
.../paimon/test_paimon_rest_catalog_write.out | 13 +
...loud_mow_load_preserves_schema_change_lock.out} | 5 +-
regression-test/data/mtmv_p0/test_paimon_mtmv.out | 3 +-
.../data/nereids_syntax_p0/agg_4_phase.out | 2 +
.../test_paimon_create_ddl_write_properties.out | 84 +
.../paimon_write/test_paimon_write_append_only.out | 43 +
.../test_paimon_write_bucket_modes.out | 56 +
.../test_paimon_write_changelog_producer.out | 27 +
.../test_paimon_write_compaction.out} | 12 +-
.../test_paimon_write_complex_types.out | 36 +
.../paimon_write/test_paimon_write_edge_cases.out | 30 +
.../paimon_write/test_paimon_write_failures.out | 32 +
.../test_paimon_write_merge_engine.out | 15 +
.../data/paimon_write/test_paimon_write_pk.out | 52 +
.../test_paimon_write_schema_change.out | 532 ++++
.../paimon_write/test_paimon_write_transaction.out | 150 +
.../data/paimon_write/test_paimon_write_types.out | 37 +
..._agg_after_nested_loop_join_local_exchange.out} | 4 +-
.../variant_p0/test_variant_equality_contexts.out | 39 +
.../test_variant_ordering_comparison_error.out | 16 +
.../data/variant_p0/variant_compute_v2.out | 235 ++
.../data/variant_p0/variant_parse_functions.out | 24 +
.../suites/autobucket/test_autobucket.groovy | 4 +-
.../cloud_p0/cache/ttl/alter_ttl_max_int64.groovy | 41 +-
.../cloud_p0/multi_cluster/test_auto_start.groovy | 4 +
...test_cloud_colocate_consistent_hash_join.groovy | 67 +
.../multi_cluster/test_unfinished_txn_2pc.groovy | 117 +
..._timestamptz_partition_boundary_timezone.groovy | 257 ++
.../PAIMON_ICEBERG_READ_WRITE_P0_COVERAGE.md | 103 +
...ceberg_branch_tag_schema_change_extended.groovy | 7 +-
.../iceberg/iceberg_branch_tag_operate.groovy | 4 +-
.../iceberg/iceberg_query_tag_branch.groovy | 39 +-
.../iceberg_schema_change_ddl_with_branch.groovy | 24 +-
...test_iceberg_schema_dual_relation_matrix.groovy | 69 +-
...iceberg_schema_metadata_atomicity_matrix.groovy | 7 +-
.../test_iceberg_schema_ref_actions_matrix.groovy | 70 +-
.../test_iceberg_schema_time_travel_matrix.groovy | 33 +-
.../iceberg/write/ICEBERG_WRITE_P0_COVERAGE.md | 16 +-
...rg_write_merge_duplicate_source_negative.groovy | 93 +-
...st_iceberg_write_merge_truncate_negative.groovy | 15 +-
...iceberg_write_nullable_truncate_negative.groovy | 8 -
.../paimon/paimon_data_system_table.groovy | 21 +
.../paimon/paimon_incr_read.groovy | 57 +-
.../paimon/paimon_schema_change_ddl.groovy | 398 +++
.../paimon/paimon_system_table.groovy | 71 +-
.../paimon/paimon_time_travel.groovy | 8 +
.../test_paimon_ctas_atomicity_negative.groovy | 82 +
.../paimon/test_paimon_merge_engine_matrix.groovy | 223 ++
...st_paimon_schema_branch_partition_matrix.groovy | 15 +-
.../test_paimon_schema_dual_relation_matrix.groovy | 53 +-
.../test_paimon_schema_time_travel_matrix.groovy | 154 +-
.../paimon/test_paimon_write_boundary.groovy | 101 +
.../tvf/test_hdfs_parquet_group5.groovy | 8 +-
.../tvf/test_hdfs_parquet_group6.groovy | 8 +-
.../external_table_p0/tvf/test_http_tvf.groovy | 9 +-
.../test_external_catalog_maxcompute.groovy | 6 +-
.../maxcompute/test_max_compute_schema.groovy | 5 +-
.../test_max_compute_validate_connection.groovy | 102 +
.../paimon/test_paimon_hms_catalog_write.groovy | 113 +
.../paimon/test_paimon_rest_catalog_write.groovy | 108 +
...ud_mow_load_preserves_schema_change_lock.groovy | 101 +
.../suites/meta_action_p0/test_dump_image.groovy | 1 +
.../suites/mtmv_p0/test_paimon_mtmv.groovy | 7 +-
.../suites/nereids_syntax_p0/agg_4_phase.groovy | 25 +-
.../test_paimon_create_ddl_write_properties.groovy | 400 +++
.../test_paimon_write_append_only.groovy | 219 ++
.../test_paimon_write_bucket_modes.groovy | 497 ++++
.../test_paimon_write_changelog_producer.groovy | 293 ++
.../test_paimon_write_compaction.groovy | 179 ++
.../test_paimon_write_complex_types.groovy | 293 ++
.../test_paimon_write_edge_cases.groovy | 140 +
.../paimon_write/test_paimon_write_failures.groovy | 187 ++
.../test_paimon_write_merge_engine.groovy | 155 ++
.../paimon_write/test_paimon_write_pk.groovy | 197 ++
.../test_paimon_write_schema_change.groovy | 1097 ++++++++
.../test_paimon_write_transaction.groovy | 466 ++++
.../paimon_write/test_paimon_write_types.groovy | 203 ++
.../sql/auto_partition_quorum_race_docker.groovy | 98 +
...gg_after_nested_loop_join_local_exchange.groovy | 130 +
.../test_agg_schema_value_drop.groovy | 7 +-
.../test_dup_schema_value_drop.groovy | 7 +-
.../test_variant_equality_contexts.groovy | 289 ++
.../test_variant_ordering_comparison_error.groovy | 110 +
.../suites/variant_p0/variant_compute_v2.groovy | 708 +++++
.../variant_p0/variant_parse_functions.groovy | 121 +
thirdparty/LICENSE.txt | 10 +
thirdparty/build-thirdparty.sh | 75 +
thirdparty/vars.sh | 7 +
668 files changed, 65262 insertions(+), 2176 deletions(-)
create mode 100644 be/src/core/column/variant_v2/column_variant_v2.cpp
create mode 100644 be/src/core/column/variant_v2/column_variant_v2.h
create mode 100644
be/src/core/column/variant_v2/column_variant_v2_read_view.cpp
copy
fe/fe-core/src/main/java/org/apache/doris/datasource/paimon/PaimonSnapshotCacheValue.java
=> be/src/core/column/variant_v2/column_variant_v2_typed_column.cpp (52%)
create mode 100644
be/src/core/column/variant_v2/column_variant_v2_typed_column.h
create mode 100644 be/src/core/data_type/data_type_variant_v2.cpp
create mode 100644 be/src/core/data_type/data_type_variant_v2.h
create mode 100644 be/src/core/data_type_serde/data_type_variant_v2_serde.cpp
create mode 100644 be/src/core/data_type_serde/data_type_variant_v2_serde.h
create mode 100644 be/src/core/data_type_serde/orc_serde_utils.h
create mode 100644 be/src/core/value/variant/variant_batch_builder.cpp
create mode 100644 be/src/core/value/variant/variant_batch_builder.h
create mode 100644 be/src/core/value/variant/variant_canonical.cpp
create mode 100644 be/src/core/value/variant/variant_canonical.h
create mode 100644 be/src/core/value/variant/variant_field.cpp
create mode 100644 be/src/core/value/variant/variant_field.h
create mode 100644 be/src/core/value/variant/variant_metadata.cpp
copy
fe/fe-core/src/main/java/org/apache/doris/transaction/IcebergTransactionManager.java
=> be/src/core/value/variant/variant_metadata.h (53%)
create mode 100644 be/src/core/value/variant/variant_parquet_encoding.h
create mode 100644 be/src/core/value/variant/variant_scalar.cpp
create mode 100644 be/src/core/value/variant/variant_scalar.h
create mode 100644 be/src/core/value/variant/variant_value.cpp
create mode 100644 be/src/core/value/variant/variant_value.h
create mode 100644 be/src/exec/operator/paimon_table_sink_operator.cpp
create mode 100644 be/src/exec/operator/paimon_table_sink_operator.h
copy
fe/fe-core/src/main/java/org/apache/doris/transaction/IcebergTransactionManager.java
=> be/src/exec/sink/writer/paimon/ffi_paimon_write_backend.cpp (61%)
copy
fe/fe-core/src/main/java/org/apache/doris/datasource/paimon/PaimonSnapshotCacheValue.java
=> be/src/exec/sink/writer/paimon/ffi_paimon_write_backend.h (53%)
create mode 100644 be/src/exec/sink/writer/paimon/jni_paimon_write_backend.cpp
create mode 100644 be/src/exec/sink/writer/paimon/jni_paimon_write_backend.h
create mode 100644 be/src/exec/sink/writer/paimon/paimon_jni_memory_manager.cpp
create mode 100644 be/src/exec/sink/writer/paimon/paimon_jni_memory_manager.h
create mode 100644 be/src/exec/sink/writer/paimon/paimon_table_writer.cpp
create mode 100644 be/src/exec/sink/writer/paimon/paimon_table_writer.h
create mode 100644 be/src/exec/sink/writer/paimon/paimon_write_backend.h
create mode 100644
be/src/exec/sink/writer/paimon/paimon_write_backend_factory.cpp
create mode 100644
be/src/exprs/function/cast/variant_v2/cast_array_to_variant.cpp
create mode 100644
be/src/exprs/function/cast/variant_v2/cast_variant_to_array.cpp
create mode 100644
be/src/exprs/function/cast/variant_v2/cast_variant_to_jsonb.cpp
create mode 100644
be/src/exprs/function/cast/variant_v2/cast_variant_to_scalar.cpp
create mode 100644
be/src/exprs/function/cast/variant_v2/cast_variant_to_string.cpp
create mode 100644 be/src/exprs/function/cast/variant_v2/cast_variant_v2.cpp
copy
fe/fe-core/src/main/java/org/apache/doris/datasource/paimon/PaimonMvccSnapshot.java
=> be/src/exprs/function/cast/variant_v2/cast_variant_v2.h (63%)
create mode 100644
be/src/exprs/function/cast/variant_v2/cast_variant_v2_internal.h
create mode 100644 be/src/exprs/function/function_variant_element_v2.cpp
create mode 100644 be/src/exprs/function/function_variant_element_v2.h
create mode 100644 be/src/exprs/function/function_variant_parse.cpp
create mode 100644 be/src/exprs/function/parse/variant_jsonb_parse.cpp
create mode 100644 be/src/exprs/function/parse/variant_jsonb_parse.h
create mode 100644 be/src/exprs/function/parse/variant_string_parse.cpp
create mode 100644 be/src/exprs/function/parse/variant_string_parse.h
create mode 100644 be/src/exprs/vtopn_pred.cpp
copy
fe/fe-core/src/main/java/org/apache/doris/datasource/mvcc/EmptyMvccSnapshot.java
=> be/src/format_v2/parquet/reader/direct_predicate.h (63%)
create mode 100644 be/src/util/bthread_shared_mutex.h
create mode 100644 be/test/core/column/column_variant_v2_test.cpp
create mode 100644
be/test/core/data_type_serde/data_type_variant_v2_serde_binary_roundtrip_test.cpp
create mode 100644
be/test/core/data_type_serde/data_type_variant_v2_serde_input_test.cpp
create mode 100644
be/test/core/data_type_serde/data_type_variant_v2_serde_jsonb_test.cpp
create mode 100644
be/test/core/data_type_serde/data_type_variant_v2_serde_output_test.cpp
copy
fe/fe-core/src/main/java/org/apache/doris/datasource/mvcc/EmptyMvccSnapshot.java
=> be/test/exec/sink/writer/paimon/paimon_write_backend_test.cpp (63%)
create mode 100644
be/test/exprs/aggregate/aggregate_function_uniq_variant_test.cpp
create mode 100644
be/test/exprs/function/cast/cast_variant_v2_benchmark_test.cpp
create mode 100644 be/test/exprs/function/cast/cast_variant_v2_from_test.cpp
create mode 100644 be/test/exprs/function/cast/cast_variant_v2_to_test.cpp
create mode 100644
be/test/exprs/function/function_variant_element_v2_encoded_test.cpp
create mode 100644
be/test/exprs/function/function_variant_element_v2_string_test.cpp
create mode 100644 be/test/exprs/function/function_variant_parse_test.cpp
copy
fe/fe-core/src/main/java/org/apache/doris/transaction/MCTransactionManager.java
=> be/test/exprs/variant_v2_execution_test.cpp (59%)
create mode 100644 be/test/util/bthread_shared_mutex_test.cpp
create mode 100644 be/test/util/variant/testdata/ParquetVariantGolden.java
create mode 100644
be/test/util/variant/testdata/doris_java_verified_vectors.tsv
create mode 100644 be/test/util/variant/testdata/parquet_java_vectors.tsv
create mode 100644 be/test/util/variant/variant_batch_builder_test.cpp
create mode 100644 be/test/util/variant/variant_canonical_test.cpp
create mode 100644 be/test/util/variant/variant_field_test.cpp
create mode 100644 be/test/util/variant/variant_golden_vector_test.cpp
create mode 100644 be/test/util/variant/variant_jsonb_parse_test.cpp
create mode 100644 be/test/util/variant/variant_string_parse_test.cpp
create mode 100644 be/test/util/variant/variant_test_utils.cpp
create mode 100644 be/test/util/variant/variant_test_utils.h
create mode 100644 be/test/util/variant/variant_value_test.cpp
create mode 100644 dist/licenses/LICENSE-lance-c-rust-crates.txt
rename fe/be-java-extensions/{paimon-scanner => paimon-connector}/pom.xml (93%)
create mode 100644
fe/be-java-extensions/paimon-connector/src/main/java/org/apache/doris/paimon/DorisMemorySegmentPool.java
create mode 100644
fe/be-java-extensions/paimon-connector/src/main/java/org/apache/doris/paimon/GlobalIndexAssigner.java
create mode 100644
fe/be-java-extensions/paimon-connector/src/main/java/org/apache/doris/paimon/PaimonArrowConverter.java
rename fe/be-java-extensions/{paimon-scanner =>
paimon-connector}/src/main/java/org/apache/doris/paimon/PaimonColumnValue.java
(95%)
create mode 100644
fe/be-java-extensions/paimon-connector/src/main/java/org/apache/doris/paimon/PaimonCommitCodec.java
rename fe/be-java-extensions/{paimon-scanner =>
paimon-connector}/src/main/java/org/apache/doris/paimon/PaimonJdbcDriverUtils.java
(100%)
rename fe/be-java-extensions/{paimon-scanner =>
paimon-connector}/src/main/java/org/apache/doris/paimon/PaimonJniScanner.java
(96%)
create mode 100644
fe/be-java-extensions/paimon-connector/src/main/java/org/apache/doris/paimon/PaimonJniWriter.java
rename fe/be-java-extensions/{paimon-scanner =>
paimon-connector}/src/main/java/org/apache/doris/paimon/PaimonTypeUtils.java
(100%)
rename fe/be-java-extensions/{paimon-scanner =>
paimon-connector}/src/main/java/org/apache/doris/paimon/PaimonUtils.java (100%)
create mode 100644
fe/be-java-extensions/paimon-connector/src/main/java/org/apache/doris/paimon/PaimonWriteSchema.java
rename fe/be-java-extensions/{paimon-scanner =>
paimon-connector}/src/main/resources/package.xml (100%)
copy
fe/{fe-core/src/main/java/org/apache/doris/datasource/paimon/PaimonSnapshotCacheValue.java
=>
be-java-extensions/paimon-connector/src/test/java/org/apache/doris/paimon/GlobalIndexAssignerTest.java}
(50%)
create mode 100644
fe/be-java-extensions/paimon-connector/src/test/java/org/apache/doris/paimon/PaimonArrowConverterTest.java
create mode 100644
fe/be-java-extensions/paimon-connector/src/test/java/org/apache/doris/paimon/PaimonColumnValueTest.java
create mode 100644
fe/be-java-extensions/paimon-connector/src/test/java/org/apache/doris/paimon/PaimonCommitCodecTest.java
rename fe/be-java-extensions/{paimon-scanner =>
paimon-connector}/src/test/java/org/apache/doris/paimon/PaimonJdbcDriverUtilsTest.java
(100%)
rename fe/be-java-extensions/{paimon-scanner =>
paimon-connector}/src/test/java/org/apache/doris/paimon/PaimonJniScannerTest.java
(100%)
create mode 100644
fe/be-java-extensions/paimon-connector/src/test/java/org/apache/doris/paimon/PaimonJniWriterTest.java
create mode 100644
fe/be-java-extensions/paimon-connector/src/test/java/org/apache/doris/paimon/PaimonWriteSchemaTest.java
create mode 100644
fe/fe-common/src/main/java/org/apache/doris/common/MetaServiceRpcRateLimitConfigValidator.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/cloud/catalog/CloudColocatePlacement.java
copy
fe/fe-core/src/main/java/org/apache/doris/{datasource/mvcc/EmptyMvccSnapshot.java
=> cloud/rpc/MetaServiceRateLimitException.java} (69%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/cloud/rpc/MetaServiceRpcRateLimiter.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/paimon/PaimonScanParams.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/paimon/PaimonTransaction.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/paimon/PaimonWriteBinding.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/paimon/PaimonWriteTarget.java
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/analyzer/{UnboundIcebergTableSink.java
=> UnboundPaimonTableSink.java} (55%)
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/implementation/{LogicalIcebergTableSinkToPhysicalIcebergTableSink.java
=> LogicalPaimonTableSinkToPhysicalPaimonTableSink.java} (67%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/NullToNonNullFunction.java
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/{NotNullOrEmpty.java
=> ParseToVariant.java} (61%)
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/{NullOrEmpty.java
=> TryParseToVariant.java} (62%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/insert/PaimonInsertCommandContext.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/insert/PaimonInsertExecutor.java
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/logical/{LogicalIcebergTableSink.java
=> LogicalPaimonTableSink.java} (62%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/physical/PhysicalPaimonTableSink.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/planner/PaimonTableSink.java
copy
fe/fe-core/src/main/java/org/apache/doris/transaction/{IcebergTransactionManager.java
=> PaimonTransactionManager.java} (64%)
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/catalog/TablePropertyTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/cloud/catalog/CloudColocatePlacementTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/cloud/catalog/CloudUpgradeMgrTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/cloud/rpc/MetaServiceRpcRateLimiterTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/common/proc/ColocationGroupProcDirTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/common/proc/PartitionsProcDirTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/common/proc/TabletHealthProcDirTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/common/util/HttpURLUtilTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/iceberg/IcebergSysExternalTableTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/iceberg/rewrite/RewriteDataFileExecutorTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/maxcompute/MCTransactionTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/maxcompute/MaxComputeExternalCatalogTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/maxcompute/source/MaxComputeScanNodeTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/paimon/PaimonExternalTableTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/paimon/PaimonScanParamsTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/paimon/PaimonTransactionTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/paimon/PaimonWriteBindingTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/paimon/PaimonWriteTargetTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/paimon/source/PaimonSourceTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/httpv2/meta/MetaServiceTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/analyzer/UnboundIcebergTableSinkTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/rules/analysis/VariantEqualityContextTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/rules/rewrite/PruneFileScanPartitionTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/expressions/literal/StructLiteralTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/plans/commands/CreateTableCommandTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/plans/commands/ExecuteCommandTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/plans/physical/PhysicalPaimonTableSinkTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/planner/IcebergTableSinkTest.java
copy
regression-test/data/{external_table_p0/iceberg/write/test_iceberg_write_merge_duplicate_source_negative.out
=> cloud_p0/multi_cluster/test_cloud_colocate_consistent_hash_join.out} (65%)
create mode 100644
regression-test/data/datatype_p0/timestamptz/test_timestamptz_partition_boundary_timezone.out
create mode 100644
regression-test/data/external_table_p0/iceberg/test_iceberg_schema_dual_relation_matrix.out
create mode 100644
regression-test/data/external_table_p0/iceberg/test_iceberg_schema_ref_actions_matrix.out
create mode 100644
regression-test/data/external_table_p0/iceberg/test_iceberg_schema_time_travel_matrix.out
create mode 100644
regression-test/data/external_table_p0/paimon/paimon_schema_change_ddl.out
create mode 100644
regression-test/data/external_table_p0/paimon/test_paimon_merge_engine_matrix.out
copy
regression-test/data/external_table_p0/{iceberg/write/test_iceberg_write_merge_duplicate_source_negative.out
=> paimon/test_paimon_schema_branch_partition_matrix.out} (53%)
create mode 100644
regression-test/data/external_table_p0/paimon/test_paimon_schema_dual_relation_matrix.out
create mode 100644
regression-test/data/external_table_p0/paimon/test_paimon_schema_time_travel_matrix.out
create mode 100644
regression-test/data/external_table_p0/paimon/test_paimon_write_boundary.out
create mode 100644
regression-test/data/external_table_p2/paimon/test_paimon_hms_catalog_write.out
create mode 100644
regression-test/data/external_table_p2/paimon/test_paimon_rest_catalog_write.out
copy
regression-test/data/{external_table_p0/iceberg/write/test_iceberg_write_merge_duplicate_source_negative.out
=>
fault_injection_p0/cloud/test_cloud_mow_load_preserves_schema_change_lock.out}
(65%)
create mode 100644
regression-test/data/paimon_write/test_paimon_create_ddl_write_properties.out
create mode 100644
regression-test/data/paimon_write/test_paimon_write_append_only.out
create mode 100644
regression-test/data/paimon_write/test_paimon_write_bucket_modes.out
create mode 100644
regression-test/data/paimon_write/test_paimon_write_changelog_producer.out
copy
regression-test/data/{external_table_p0/iceberg/write/test_iceberg_write_merge_duplicate_source_negative.out
=> paimon_write/test_paimon_write_compaction.out} (50%)
create mode 100644
regression-test/data/paimon_write/test_paimon_write_complex_types.out
create mode 100644
regression-test/data/paimon_write/test_paimon_write_edge_cases.out
create mode 100644
regression-test/data/paimon_write/test_paimon_write_failures.out
create mode 100644
regression-test/data/paimon_write/test_paimon_write_merge_engine.out
create mode 100644 regression-test/data/paimon_write/test_paimon_write_pk.out
create mode 100644
regression-test/data/paimon_write/test_paimon_write_schema_change.out
create mode 100644
regression-test/data/paimon_write/test_paimon_write_transaction.out
create mode 100644
regression-test/data/paimon_write/test_paimon_write_types.out
copy
regression-test/data/{external_table_p0/iceberg/write/test_iceberg_write_merge_duplicate_source_negative.out
=> query_p0/join/test_agg_after_nested_loop_join_local_exchange.out} (65%)
create mode 100644
regression-test/data/variant_p0/test_variant_equality_contexts.out
create mode 100644
regression-test/data/variant_p0/test_variant_ordering_comparison_error.out
create mode 100644 regression-test/data/variant_p0/variant_compute_v2.out
create mode 100644 regression-test/data/variant_p0/variant_parse_functions.out
create mode 100644
regression-test/suites/cloud_p0/multi_cluster/test_cloud_colocate_consistent_hash_join.groovy
create mode 100644
regression-test/suites/cloud_p0/multi_cluster/test_unfinished_txn_2pc.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamptz/test_timestamptz_partition_boundary_timezone.groovy
create mode 100644
regression-test/suites/external_table_p0/PAIMON_ICEBERG_READ_WRITE_P0_COVERAGE.md
create mode 100644
regression-test/suites/external_table_p0/paimon/paimon_schema_change_ddl.groovy
create mode 100644
regression-test/suites/external_table_p0/paimon/test_paimon_ctas_atomicity_negative.groovy
create mode 100644
regression-test/suites/external_table_p0/paimon/test_paimon_merge_engine_matrix.groovy
create mode 100644
regression-test/suites/external_table_p0/paimon/test_paimon_write_boundary.groovy
create mode 100644
regression-test/suites/external_table_p2/maxcompute/test_max_compute_validate_connection.groovy
create mode 100644
regression-test/suites/external_table_p2/paimon/test_paimon_hms_catalog_write.groovy
create mode 100644
regression-test/suites/external_table_p2/paimon/test_paimon_rest_catalog_write.groovy
create mode 100644
regression-test/suites/fault_injection_p0/cloud/test_cloud_mow_load_preserves_schema_change_lock.groovy
create mode 100644
regression-test/suites/paimon_write/test_paimon_create_ddl_write_properties.groovy
create mode 100644
regression-test/suites/paimon_write/test_paimon_write_append_only.groovy
create mode 100644
regression-test/suites/paimon_write/test_paimon_write_bucket_modes.groovy
create mode 100644
regression-test/suites/paimon_write/test_paimon_write_changelog_producer.groovy
create mode 100644
regression-test/suites/paimon_write/test_paimon_write_compaction.groovy
create mode 100644
regression-test/suites/paimon_write/test_paimon_write_complex_types.groovy
create mode 100644
regression-test/suites/paimon_write/test_paimon_write_edge_cases.groovy
create mode 100644
regression-test/suites/paimon_write/test_paimon_write_failures.groovy
create mode 100644
regression-test/suites/paimon_write/test_paimon_write_merge_engine.groovy
create mode 100644
regression-test/suites/paimon_write/test_paimon_write_pk.groovy
create mode 100644
regression-test/suites/paimon_write/test_paimon_write_schema_change.groovy
create mode 100644
regression-test/suites/paimon_write/test_paimon_write_transaction.groovy
create mode 100644
regression-test/suites/paimon_write/test_paimon_write_types.groovy
create mode 100644
regression-test/suites/partition_p1/auto_partition/sql/auto_partition_quorum_race_docker.groovy
create mode 100644
regression-test/suites/query_p0/join/test_agg_after_nested_loop_join_local_exchange.groovy
create mode 100644
regression-test/suites/variant_p0/test_variant_equality_contexts.groovy
create mode 100644
regression-test/suites/variant_p0/test_variant_ordering_comparison_error.groovy
create mode 100644 regression-test/suites/variant_p0/variant_compute_v2.groovy
create mode 100644
regression-test/suites/variant_p0/variant_parse_functions.groovy
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
