This is an automated email from the ASF dual-hosted git repository.
CalvinKirs pushed a change to branch 4.1-62196
in repository https://gitbox.apache.org/repos/asf/doris.git
from 401a92db8a9 [chore](fe) Merge branch-4.1 into 4.1-62196
add 612dec77ffb branch-4.1: [feature](paimon) Support row-level UPDATE,
DELETE, and MERGE (#66498)
add 042429a7cfa branch-4.1: [improvement](be) Optimize Variant V2
ingestion and STRING casts (#66744)
add 59bc3b59a60 branch-4.1: [fix](be) Use serialized hash keys for complex
types #66777 (#66828)
add 812dc99ea94 branch-4.1: [fix](show) apply ORDER BY and LIMIT correctly
to SHOW TABLETS (#65871) #66116 (#66757)
add 984c535c987 branch-4.1: [fix](feut) fix flakey MetaServiceProxyTest
#66219 (#66852)
add 13a108d04be branch-4.1: [opt](filescan) Reuse external scan tasks
within a statement (#66473)
add f0a6007cde1 branch-4.1: [chore](external) Upgrade Hive shade and align
BE exec version (#66907)
add 325838070a3 branch-4.1:[improvement](fe) Infer set operator distinct
by NDV #64618 (#66859)
add beacc07f920 branch-4.1: [fix](bvar) Fix bvar leak after schema change
job in be failed #56207 (#66946)
add 6bf7b361b41 branch-4.1: [fix](be) Fix TIMESTAMPTZ nullable type
equality #66722 (#66945)
add 1b4b44d864c branch-4.1: [fix](security) Mask private key password in
backend configuration #66836 (#66933)
add b0a79b27bb2 branch-4.1: [fix](security) Mask sensitive fields in
encryption keys schema table #66834 (#66931)
add 97500fe0c4c [branch-4.1][fix](load) Avoid global BE auth precheck for
stream load (#66629) (#66924)
add cd688e57580 branch-4.1: [fix](test) Backport TPC-H SF100 MOR
regression suite #61762 #62335 (#66915)
add 3e01e0f8dc2 branch-4.1: [fix](cloud) recycler
decrement_delete_bitmap_packed_file_ref_counts method should read delete
bitmaps as blobs #66728 (#66892)
add 6fbbcc8fd08 [branch-4.0] pick some arrow memory leak fix to branch-4.0
(#66462) (#66871)
add de6e819db1c branch-4.1: [fix](mtmv) reuse Gson instance in
MTMVTask.getTvfInfo to avoid Master FE CPU spike #66792 (#66845)
add f99471b5680 branch-4.1: [fix](be) Synchronize load error log access
#66250 (#66887)
add c3865359edc branch-4.1: [fix](job) keep Kafka metadata requests in
compute group (#66866)
add 5f72265e23a branch-4.1: [fix](job) Avoid adaptive batching for Kafka
tasks with low lag (#66863)
add 8fdcc4d0b60 branch-4.1: [improvement](be) Add CPU-aware S3 rate
limiter #65420 (#66896)
add cd4f9f14e79 branch-4.1: [fix](metrics) update real emails with
placeholder in MetricsTest #66937 (#66975)
add f77661a1b40 branch-4.1: [fix](job) Clear transaction ID after aborting
broker load transaction #66884 (#66920)
add 5dcf1066af4 [opt](lance) Support distributed execution for
vector_search (#66841)
add 93a771d4beb branch-4.1: [improvement](be) Speed up unshredded Parquet
Variant extraction (#66910)
add f44b3fa49e2 [test](lance) Add query coverage for the remaining ANN
index types and vector element types (#66512)
add 0eef45d593a branch-4.1: [fix](test) Fix external_table_p0 DATETIME
baselines and Iceberg object counting #66970 (#66994)
add e475546ffef branch-4.1: [fix](cloud) Retain instance tombstones after
recycle cleanup #66870 (#66996)
add f320323ee0e branch-4.1: [fix](auth) Mask credentials in authentication
and Stream Load logs (#66917)
add 970d951f1e9 branch-4.1: [refactor](snapshot) Allow overriding snapshot
manager factory source #66923 (#66974)
add a806cc2bc43 branch-4.1: [fix](load)(regression-test) fix broker load
label self-conflict on pending retry; deflake P2 suites #66469 (#66995)
add e15f6636dd5 branch-4.1: [test](variant) Add typed path bloom filter
regression #64573 (#67003)
add 2aa7c6fe04f branch-4.1: [refactor](snapshot) Add cloud snapshot
handler SPI and Env override #66916 (#66971)
add 721a828e657 [bugfix](jnileak) should use jni util to get jni env
(#66990)
add 414322bb588 [improvement](external) Refine Parquet splits by row group
in BE (#66802)
add 7175b4d187f Merge remote-tracking branch 'rich/branch-4.1' into
4.1-62196
No new revisions were added by this update.
Summary of changes:
be/src/agent/be_exec_version_manager.cpp | 6 +-
be/src/agent/be_exec_version_manager.h | 2 +-
be/src/agent/task_worker_pool.cpp | 13 +-
be/src/cloud/cloud_storage_engine.cpp | 12 +-
be/src/common/config.cpp | 31 +
be/src/common/config.h | 16 +
be/src/common/daemon.cpp | 17 +
be/src/common/daemon.h | 1 +
be/src/core/data_type/data_type_timestamptz.h | 4 +-
be/src/core/value/variant/variant_metadata.cpp | 16 +-
be/src/core/value/variant/variant_metadata.h | 1 +
be/src/core/value/variant/variant_value.cpp | 48 +-
be/src/core/value/variant/variant_value.h | 23 +-
be/src/exec/common/hash_table/hash_key_type.h | 3 +-
be/src/exec/operator/file_scan_operator.cpp | 63 +-
be/src/exec/operator/file_scan_operator.h | 14 +
be/src/exec/operator/materialization_opertor.cpp | 75 +-
be/src/exec/rowid_fetcher.cpp | 195 ++-
be/src/exec/rowid_fetcher.h | 13 +-
be/src/exec/scan/file_scanner_v2.cpp | 227 +++-
be/src/exec/scan/file_scanner_v2.h | 49 +
be/src/exec/scan/split_source_connector.cpp | 106 ++
be/src/exec/scan/split_source_connector.h | 22 +
.../writer/paimon/jni_paimon_write_backend.cpp | 50 +-
.../sink/writer/paimon/jni_paimon_write_backend.h | 9 +
.../cast/variant_v2/cast_variant_to_string.cpp | 9 +-
be/src/format_v2/column_mapper.cpp | 21 +
be/src/format_v2/file_reader.cpp | 5 +-
be/src/format_v2/file_reader.h | 40 +
be/src/format_v2/file_scan_context.h | 117 ++
be/src/format_v2/jni/jni_table_reader.cpp | 7 +-
be/src/format_v2/jni/jni_table_reader.h | 4 +-
be/src/format_v2/orc/orc_reader.cpp | 204 +++-
be/src/format_v2/orc/orc_reader.h | 23 +-
be/src/format_v2/parquet/parquet_file_context.cpp | 93 +-
be/src/format_v2/parquet/parquet_file_context.h | 31 +-
be/src/format_v2/parquet/parquet_profile.cpp | 15 +
be/src/format_v2/parquet/parquet_profile.h | 11 +
be/src/format_v2/parquet/parquet_reader.cpp | 134 ++-
be/src/format_v2/parquet/parquet_reader.h | 12 +-
be/src/format_v2/parquet/parquet_scan.cpp | 116 +-
be/src/format_v2/parquet/parquet_scan.h | 38 +-
.../parquet/reader/variant_column_reader.cpp | 713 ++++++++++-
be/src/format_v2/table/hudi_reader.cpp | 17 +-
be/src/format_v2/table/hudi_reader.h | 6 +-
be/src/format_v2/table/lance_reader.cpp | 335 ++++--
be/src/format_v2/table/lance_reader.h | 18 +-
be/src/format_v2/table/paimon_reader.cpp | 17 +-
be/src/format_v2/table/paimon_reader.h | 6 +-
be/src/format_v2/table_reader.cpp | 368 +++++-
be/src/format_v2/table_reader.h | 40 +-
.../schema_encryption_keys_scanner.cpp | 6 +-
be/src/io/fs/azure_obj_storage_client.cpp | 93 +-
be/src/io/fs/rate_limited_obj_storage_client.cpp | 145 +++
be/src/io/fs/rate_limited_obj_storage_client.h | 70 ++
be/src/io/fs/s3_file_system.cpp | 13 +-
be/src/io/fs/s3_obj_storage_client.cpp | 70 +-
be/src/load/stream_load/stream_load_executor.cpp | 22 +-
be/src/runtime/runtime_state.cpp | 87 +-
be/src/runtime/runtime_state.h | 5 +-
be/src/service/http/action/http_stream.cpp | 14 +-
be/src/service/http/action/http_stream.h | 6 +-
be/src/service/http/action/stream_load.cpp | 15 +-
be/src/service/http/action/stream_load.h | 6 +-
be/src/service/http/action/stream_load_2pc.cpp | 8 +-
be/src/service/http/action/stream_load_2pc.h | 5 +-
be/src/service/http/http_handler_with_auth.cpp | 8 +-
be/src/service/http/http_request.cpp | 2 +-
.../segment/adaptive_block_size_predictor.h | 7 +
be/src/storage/segment/condition_cache.h | 16 +
.../segment/variant/v2/variant_path_builder.cpp | 180 ++-
.../segment/variant/v2/variant_path_builder.h | 5 +
.../segment/variant/v2/variant_shredder.cpp | 145 ++-
.../storage/segment/variant/v2/variant_shredder.h | 8 +
be/src/storage/utils.h | 85 +-
be/src/util/s3_rate_limiter_manager.cpp | 233 ++++
be/src/util/s3_rate_limiter_manager.h | 122 ++
be/src/util/s3_util.cpp | 102 +-
be/src/util/s3_util.h | 32 +-
be/test/common/config_test.cpp | 6 +-
.../core/data_type/data_type_timestamptz_test.cpp | 20 +-
.../exec/common/hash_table/hash_key_type_test.cpp | 60 +
.../operator/materialization_shared_state_test.cpp | 72 +-
be/test/exec/scan/file_scanner_v2_test.cpp | 513 ++++++++
.../schema_encryption_keys_scanner_test.cpp | 17 +-
.../writer/paimon/paimon_write_backend_test.cpp | 21 +
.../function/cast/cast_variant_v2_from_test.cpp | 62 +
be/test/format/orc/orc_read_lines.cpp | 4 +-
be/test/format/parquet/parquet_read_lines.cpp | 4 +-
be/test/format_v2/jni/jni_table_reader_test.cpp | 14 +
be/test/format_v2/orc/orc_reader_test.cpp | 127 +-
.../parquet/parquet_reader_control_test.cpp | 59 +-
be/test/format_v2/parquet/parquet_reader_test.cpp | 420 ++++++-
be/test/format_v2/parquet/parquet_scan_test.cpp | 70 +-
.../parquet/variant_column_reader_test.cpp | 648 ++++++++++
be/test/format_v2/table/hudi_reader_test.cpp | 7 +-
be/test/format_v2/table/lance_reader_test.cpp | 300 ++++-
be/test/format_v2/table/paimon_reader_test.cpp | 7 +-
be/test/format_v2/table_reader_test.cpp | 818 +++++++++++++
be/test/io/client/s3_file_system_test.cpp | 25 +-
.../io/fs/rate_limited_obj_storage_client_test.cpp | 501 ++++++++
be/test/io/fs/s3_obj_stroage_client_mock_test.cpp | 43 +-
be/test/io/s3_client_factory_test.cpp | 111 ++
be/test/service/http/http_auth_test.cpp | 60 +-
be/test/storage/storage_engine_test.cpp | 1 -
.../variant/variant_column_writer_reader_test.cpp | 485 +++++++-
be/test/util/s3_rate_limiter_manager_test.cpp | 687 +++++++++++
be/test/util/s3_util_test.cpp | 28 +-
be/test/util/variant/variant_value_test.cpp | 47 +
cloud/src/common/config.h | 1 +
cloud/src/meta-service/meta_service.cpp | 23 +-
cloud/src/meta-service/meta_service_resource.cpp | 31 +-
cloud/src/recycler/recycler.cpp | 34 +-
cloud/src/resource-manager/resource_manager.cpp | 33 +-
cloud/src/resource-manager/resource_manager.h | 2 +-
cloud/src/snapshot/CMakeLists.txt | 8 +-
cloud/test/meta_service_test.cpp | 55 +
cloud/test/recycle_versioned_keys_test.cpp | 11 +-
cloud/test/recycler_operation_log_test.cpp | 2 +-
cloud/test/recycler_test.cpp | 73 +-
cloud/test/resource_test.cpp | 44 +
common/cpp/token_bucket_rate_limiter.cpp | 48 +-
common/cpp/token_bucket_rate_limiter.h | 24 +-
.../scripts/lance_build_preinstalled_catalog.py | 184 ++-
.../iceberg/scripts/lance_fixture_requirements.txt | 16 +-
.../auxiliary.idx | Bin 12017 -> 12017 bytes
.../f7df7f0a-77f9-428a-abe2-fe510132cfa0/index.idx | Bin 0 -> 592 bytes
.../0-3905e742-2db0-44e1-ad56-cd0b159e6799.txn | Bin 0 -> 352 bytes
.../1-1d77fd49-8d7b-44ac-98ea-062ed07cdc55.txn | Bin 0 -> 126 bytes
.../2-28c146c4-c5bb-4a77-aa56-69f44b86554e.txn | Bin 0 -> 196 bytes
.../_versions/18446744073709551612.manifest | Bin 0 -> 873 bytes
.../_versions/18446744073709551613.manifest | Bin 0 -> 644 bytes
.../_versions/18446744073709551614.manifest | Bin 0 -> 785 bytes
...10110001100111d378864dcfa9a71f2b65502410.lance} | Bin
...11010011110010a6cc2f4eaa978e7269ec893256.lance} | Bin
.../auxiliary.idx | Bin 0 -> 25199 bytes
.../b86c8bbc-8246-40ec-add8-541c0767bbd1/index.idx | Bin 0 -> 592 bytes
.../0-c6c7f7b9-4e6c-47cd-a4e6-d1ccdf906f8f.txn | Bin 0 -> 352 bytes
.../1-7f715afd-47f2-4bbb-8117-98f5c83101c5.txn | Bin 0 -> 126 bytes
.../2-d8509420-ada7-4ef3-9349-38b10e05e986.txn | Bin 0 -> 197 bytes
.../_versions/18446744073709551612.manifest | Bin 0 -> 875 bytes
.../_versions/18446744073709551613.manifest | Bin 0 -> 644 bytes
.../_versions/18446744073709551614.manifest | Bin 0 -> 785 bytes
...01011010111011e4196f4fb2af4e34597f44de02.lance} | Bin
...01000010010101891e4943169d6a864e75c5188f.lance} | Bin
.../auxiliary.idx | Bin 0 -> 29427 bytes
.../fd49bcd3-69f4-49a1-b243-f2218af4d90d/index.idx | Bin 0 -> 90952 bytes
.../0-26573fb0-fe5f-42a5-923d-676a5a48867d.txn} | Bin 352 -> 352 bytes
.../1-e02edfb0-0b30-4f00-8d65-5256646feafa.txn | Bin 0 -> 126 bytes
.../2-0de2b847-e8da-433e-b198-67eec67a9b40.txn | Bin 0 -> 203 bytes
.../_versions/18446744073709551612.manifest | Bin 0 -> 887 bytes
.../_versions/18446744073709551613.manifest | Bin 0 -> 644 bytes
.../_versions/18446744073709551614.manifest | Bin 785 -> 785 bytes
...11101010111100a6c4c14e0f8c1945b7745a4f53.lance} | Bin
...0100000101101059dd5a4247a3c800111e04933f.lance} | Bin
.../auxiliary.idx | Bin 0 -> 74289 bytes
.../b3fe52ad-845e-4174-9460-adc004837420/index.idx | Bin 0 -> 594 bytes
.../0-16aff25d-10f6-4ab9-8683-bc1cff3c9654.txn | Bin 0 -> 352 bytes
.../1-96659ad8-de9d-40bb-84bc-96155bc2e04c.txn | Bin 0 -> 126 bytes
.../2-42fa5fcb-4bf6-415d-9fb0-2573219e15c5.txn | Bin 0 -> 199 bytes
.../_versions/18446744073709551612.manifest | Bin 0 -> 879 bytes
.../_versions/18446744073709551613.manifest | Bin 0 -> 644 bytes
.../_versions/18446744073709551614.manifest | Bin 0 -> 785 bytes
...0101000101000036753c4e35998eee5f926e7181.lance} | Bin
...00110110110101c621e94ffe9ee5013b3c26331f.lance} | Bin
.../page_data.lance | Bin 0 -> 706 bytes
.../page_lookup.lance | Bin 1151 -> 1151 bytes
.../page_data.lance | Bin 576 -> 0 bytes
.../bitmap_page_lookup.lance | Bin 703 -> 767 bytes
.../bitmap_page_lookup.lance | Bin 0 -> 393 bytes
.../bitmap_page_lookup.lance | Bin 393 -> 0 bytes
.../14-2b2b0055-53cb-4e2e-a2d8-c17bb410ce79.txn | Bin 940 -> 0 bytes
.../34-68394369-30e4-4ffa-b61e-197dc759bdb5.txn | Bin 0 -> 940 bytes
.../_versions/18446744073709551580.manifest | Bin 0 -> 1949 bytes
.../_versions/18446744073709551600.manifest | Bin 1949 -> 0 bytes
.../__manifest/_versions/latest_version_hint.json | 2 +-
...11110111000110083a5334199aea08c5eacc59581.lance | Bin 0 -> 1991 bytes
...1101100100100100a8e404e57ae0aa8a08e98d5ec.lance | Bin 1667 -> 0 bytes
.../4231299b-169a-4694-b440-7fb7396b1188/index.idx | Bin 592 -> 0 bytes
.../1-050f2e5b-6487-4532-b15a-8200a82dc87b.txn | Bin 126 -> 0 bytes
.../2-8b309f5c-51bc-414c-98cf-dcc867178c25.txn | Bin 196 -> 0 bytes
.../_versions/18446744073709551612.manifest | Bin 873 -> 0 bytes
.../_versions/18446744073709551613.manifest | Bin 644 -> 0 bytes
.../auxiliary.idx | Bin 0 -> 74289 bytes
.../a4a12893-4aa7-4146-89a0-c14ff214fcdf/index.idx | Bin 0 -> 94858 bytes
.../0-fba03dae-4bc9-46cc-88e1-48d12334d9c8.txn} | Bin 352 -> 352 bytes
.../1-b7e0b480-e85b-4b2d-b640-db1e83fe0ec0.txn | Bin 0 -> 126 bytes
.../2-7cd05522-1faf-4bb3-b858-dbe3bb66f5dd.txn | Bin 0 -> 205 bytes
.../_versions/18446744073709551612.manifest | Bin 0 -> 891 bytes
.../_versions/18446744073709551613.manifest | Bin 0 -> 644 bytes
.../_versions/18446744073709551614.manifest | Bin 785 -> 785 bytes
...01110011000011fbb8834dbeb678db4c956aa2dc.lance} | Bin
...10010101000100270fdd4ff3a7fca1d1b7edc733.lance} | Bin
.../auxiliary.idx | Bin 0 -> 25199 bytes
.../89f3af0e-9900-457b-90de-840d10411bc9/index.idx | Bin 0 -> 94280 bytes
.../0-f4895c26-f312-4756-9770-212b6729b540.txn | Bin 0 -> 352 bytes
.../1-07a3d515-bca1-4363-85b9-493ffcd96d06.txn | Bin 0 -> 126 bytes
.../2-352ecaa2-290a-4dd6-a2c2-796c46d9f195.txn | Bin 0 -> 203 bytes
.../_versions/18446744073709551612.manifest | Bin 0 -> 887 bytes
.../_versions/18446744073709551613.manifest | Bin 0 -> 644 bytes
.../_versions/18446744073709551614.manifest | Bin 0 -> 785 bytes
...00100001110000e1645442cbb94bb40a5df3a0ae.lance} | Bin
...1101010110000165e42c4182a64dc3e8b72990fe.lance} | Bin
.../org/apache/doris/paimon/PaimonJniWriter.java | 9 +-
.../org/apache/doris/paimon/PaimonWriteSchema.java | 42 +
.../apache/doris/paimon/PaimonJniWriterTest.java | 2 +-
.../apache/doris/paimon/PaimonWriteSchemaTest.java | 37 +
.../main/java/org/apache/doris/common/Config.java | 2 +-
fe/fe-core/pom.xml | 83 +-
.../apache/doris/analysis/FunctionCallExpr.java | 17 +-
.../main/java/org/apache/doris/catalog/Env.java | 8 +-
.../doris/cloud/load/CloudBrokerLoadJob.java | 6 +
.../doris/cloud/snapshot/CloudSnapshotHandler.java | 36 +-
.../org/apache/doris/common/util/SortAndLimit.java | 57 +
.../apache/doris/common/util/ThriftLogHelper.java | 57 +
.../doris/datasource/ExternalScanTaskCacheKey.java | 23 +-
.../apache/doris/datasource/FileQueryScanNode.java | 103 ++
.../datasource/hive/HiveExternalMetaCache.java | 58 +-
.../doris/datasource/hive/source/HiveScanNode.java | 204 +++-
.../apache/doris/datasource/hudi/HudiUtils.java | 13 +-
.../doris/datasource/hudi/source/HudiScanNode.java | 209 +++-
.../datasource/iceberg/source/IcebergScanNode.java | 333 +++++-
.../apache/doris/datasource/kafka/KafkaUtil.java | 121 +-
.../datasource/lance/LanceExternalCatalog.java | 18 +-
.../doris/datasource/lance/LanceExternalTable.java | 5 +
.../doris/datasource/lance/LanceFragmentInfo.java | 56 +
.../datasource/lance/LanceIndexSegmentInfo.java | 70 ++
.../datasource/lance/LanceMetadataLoader.java | 93 +-
.../doris/datasource/lance/LanceTableMetadata.java | 67 +-
.../lance/source/IndexSegmentSplitPlan.java | 83 ++
.../datasource/lance/source/LanceScanNode.java | 302 ++++-
.../doris/datasource/lance/source/LanceSplit.java | 94 +-
.../paimon/PaimonRowChangeOperation.java | 21 +-
.../apache/doris/datasource/paimon/PaimonUtil.java | 65 +-
.../datasource/paimon/source/PaimonScanNode.java | 296 ++++-
.../doris/datasource/tvf/source/TVFScanNode.java | 46 +-
.../apache/doris/dictionary/DictionaryManager.java | 229 ++--
.../org/apache/doris/httpv2/rest/LoadAction.java | 3 +-
.../apache/doris/job/executor/TaskProcessor.java | 18 +
.../apache/doris/job/extensions/mtmv/MTMVTask.java | 87 +-
.../org/apache/doris/load/StreamLoadHandler.java | 3 +-
.../apache/doris/load/loadv2/BrokerLoadJob.java | 59 +-
.../load/routineload/KafkaRoutineLoadJob.java | 52 +-
.../doris/load/routineload/KafkaTaskInfo.java | 16 +-
.../org/apache/doris/nereids/StatementContext.java | 266 +++++
.../nereids/analyzer/UnboundPaimonTableSink.java | 57 +-
.../glue/translator/ExpressionTranslator.java | 4 +
.../glue/translator/PhysicalPlanTranslator.java | 3 +-
.../doris/nereids/jobs/executor/Rewriter.java | 2 +-
.../post/CommonSubExpressionCollector.java | 6 +
.../post/materialize/MaterializeProbeVisitor.java | 14 +
.../org/apache/doris/nereids/rules/RuleSet.java | 2 +
.../org/apache/doris/nereids/rules/RuleType.java | 1 +
.../nereids/rules/analysis/BindExpression.java | 55 +-
.../doris/nereids/rules/analysis/BindSink.java | 13 +
.../nereids/rules/analysis/CollectRelation.java | 10 +
.../nereids/rules/analysis/PaimonMergePlanner.java | 509 ++++++++
.../analysis/PaimonRowChangeCapabilities.java | 231 ++++
.../rules/analysis/PaimonRowChangePlanBuilder.java | 163 +++
.../rules/expression/rules/ConditionRewrite.java | 3 +-
.../rules/NestedCaseWhenCondToLiteral.java | 3 +-
...alPaimonTableSinkToPhysicalPaimonTableSink.java | 1 +
.../rules/rewrite/InferSetOperatorDistinct.java | 131 +-
.../PushDownFilterThroughVectorSearchTopN.java | 60 +
.../expressions/functions/AlwaysShortCircuit.java | 16 +-
.../functions/scalar/ShortCircuitIf.java | 26 +-
.../trees/plans/commands/DeleteFromCommand.java | 17 +
.../plans/commands/DeleteFromUsingCommand.java | 14 +
.../trees/plans/commands/PaimonDeleteCommand.java | 82 ++
.../trees/plans/commands/PaimonMergeCommand.java | 124 ++
.../trees/plans/commands/PaimonUpdateCommand.java | 91 ++
.../commands/ShowTabletsFromTableCommand.java | 67 +-
.../trees/plans/commands/UpdateCommand.java | 10 +
.../trees/plans/commands/info/DMLCommandType.java | 2 +
.../plans/commands/info/PaimonRowChangeSpec.java | 189 +++
.../trees/plans/commands/insert/InsertUtils.java | 4 +
.../plans/commands/merge/MergeIntoCommand.java | 11 +
.../plans/logical/LogicalPaimonTableSink.java | 3 +-
.../plans/physical/PhysicalPaimonTableSink.java | 38 +-
.../org/apache/doris/planner/PaimonTableSink.java | 24 +-
.../java/org/apache/doris/qe/ConnectContext.java | 34 +
.../org/apache/doris/qe/MysqlConnectProcessor.java | 14 +-
.../java/org/apache/doris/qe/SessionVariable.java | 38 +
.../java/org/apache/doris/qe/StmtExecutor.java | 44 +-
.../apache/doris/service/FrontendServiceImpl.java | 25 +-
.../arrowflight/DorisFlightSqlProducer.java | 12 +
.../arrowflight/FlightSqlConnectProcessor.java | 21 +-
.../arrowflight/results/FlightSqlChannel.java | 1 +
.../results/FlightSqlResultCacheEntry.java | 2 +-
.../sessions/FlightSqlConnectContext.java | 3 -
.../sessions/FlightSqlConnectPoolMgr.java | 20 +
.../ExternalFileTableValuedFunction.java | 9 +-
.../tablefunction/FileTableValuedFunction.java | 4 +-
.../VectorSearchTableValuedFunction.java | 94 +-
.../doris/cloud/load/CloudBrokerLoadJobTest.java | 89 ++
.../doris/cloud/rpc/MetaServiceProxyTest.java | 18 +-
.../cloud/snapshot/CloudSnapshotHandlerTest.java | 145 +++
.../apache/doris/common/util/SortAndLimitTest.java | 79 ++
.../doris/common/util/ThriftLogHelperTest.java | 73 ++
.../doris/datasource/FileQueryScanNodeTest.java | 116 ++
.../datasource/hive/HiveMetaStoreCacheTest.java | 45 +
.../datasource/hive/source/HiveScanNodeTest.java | 408 +++++++
.../datasource/hudi/source/HudiScanNodeTest.java | 424 +++++++
.../iceberg/source/IcebergScanNodeTest.java | 601 ++++++++++
.../doris/datasource/kafka/KafkaUtilTest.java | 150 +++
.../doris/datasource/lance/LanceSnapshotTest.java | 4 +-
.../datasource/lance/source/LanceScanNodeTest.java | 296 ++++-
.../paimon/source/PaimonScanNodeTest.java | 439 ++++++-
.../datasource/tvf/source/TVFScanNodeTest.java | 32 +-
.../doris/dictionary/DictionaryManagerTest.java | 25 +
.../doris/job/executor/TaskProcessorTest.java | 239 ++++
.../doris/load/loadv2/BrokerLoadJobTest.java | 171 +++
.../load/routineload/KafkaRoutineLoadJobTest.java | 228 +++-
.../doris/load/routineload/RoutineLoadJobTest.java | 7 +-
.../java/org/apache/doris/metric/MetricsTest.java | 20 +-
.../apache/doris/nereids/StatementContextTest.java | 380 ++++++
.../postprocess/CommonSubExpressionTest.java | 17 +
.../materialize/MaterializeProbeVisitorTest.java | 57 +
.../rules/NestedCaseWhenCondToLiteralTest.java | 18 +
.../expression/rules/NullSafeEqualToEqualTest.java | 19 +
.../rewrite/InferSetOperatorDistinctTest.java | 78 ++
.../trees/plans/commands/ExecuteCommandTest.java | 61 +
.../org/apache/doris/qe/ConnectContextTest.java | 58 +
.../java/org/apache/doris/qe/StmtExecutorTest.java | 36 +
.../doris/service/FrontendServiceImplTest.java | 33 +
.../arrowflight/DorisFlightSqlProducerTest.java | 65 +
.../sessions/FlightSqlConnectPoolMgrTest.java | 69 ++
.../VectorSearchTableValuedFunctionTest.java | 75 ++
fe/pom.xml | 2 +-
gensrc/proto/internal_service.proto | 7 +-
gensrc/thrift/DataSinks.thrift | 1 +
gensrc/thrift/PlanNodes.thrift | 28 +-
.../data/cloud_p0/s3/test_s3_rate_limiter.out | 6 +
.../test_group_by_fixed_width_struct.out | 23 +
.../timestamptz/test_timestamptz_struct_insert.out | 4 +
.../lance/test_lance_vector_search.out | 15 +-
.../test_lance_vector_search_element_types.out | 13 +
.../lance/test_lance_vector_search_index_types.out | 67 ++
...h.out => test_lance_vector_search_ivf_flat.out} | 16 +-
.../lance/test_lance_vector_search_two_phase.out | 26 +
.../paimon/test_paimon_write_boundary.out | 4 +-
.../test_remote_doris_all_types_select.out | 4 +-
.../remote_doris/test_remote_doris_statistics.out | 2 +-
.../infer_set_operator_distinct.out | 1250 --------------------
.../add_project_for_unique_function.out | 29 +-
...n_join_other_condition_with_unique_function.out | 1 +
.../test_paimon_write_row_level_dml.out | 49 +
.../tpcds_sf100/noStatsRfPrune/query14.out | 72 +-
.../tpcds_sf100/noStatsRfPrune/query75.out | 84 +-
.../tpcds_sf100/noStatsRfPrune/query8.out | 38 +-
.../tpcds_sf100/no_stats_shape/query14.out | 72 +-
.../tpcds_sf100/no_stats_shape/query75.out | 84 +-
.../tpcds_sf100/no_stats_shape/query8.out | 38 +-
.../shape_check/tpcds_sf100/rf_prune/query14.out | 8 +-
.../shape_check/tpcds_sf100/rf_prune/query8.out | 28 +-
.../data/shape_check/tpcds_sf100/shape/query14.out | 8 +-
.../data/shape_check/tpcds_sf100/shape/query8.out | 28 +-
.../tpcds_sf1000/bs_downgrade_shape/query8.out | 28 +-
.../data/shape_check/tpcds_sf1000/hint/query14.out | 8 +-
.../data/shape_check/tpcds_sf1000/hint/query8.out | 28 +-
.../shape_check/tpcds_sf1000/shape/query14.out | 8 +-
.../data/shape_check/tpcds_sf1000/shape/query8.out | 28 +-
.../shape_check/tpcds_sf10t_orc/shape/query14.out | 68 +-
.../shape_check/tpcds_sf10t_orc/shape/query75.out | 111 +-
.../shape_check/tpcds_sf10t_orc/shape/query8.out | 38 +-
.../runtime_filter/test_pushdown_setop.out | 10 +-
.../sql/q01.out | 0
.../sql/q02.out | 0
.../sql/q03.out | 0
.../sql/q04.out | 0
.../sql/q05.out | 0
.../sql/q06.out | 0
.../sql/q07.out | 0
.../sql/q08.out | 0
.../sql/q09.out | 0
.../sql/q10.out | 0
.../sql/q11.out | 0
.../sql/q12.out | 0
.../sql/q13.out | 0
.../sql/q14.out | 0
.../sql/q15.out | 0
.../sql/q16.out | 0
.../sql/q17.out | 0
.../sql/q18.out | 0
.../sql/q19.out | 0
.../sql/q20.out | 0
.../sql/q21.out | 0
.../sql/q22.out | 0
regression-test/plugins/plugin_compaction.groovy | 8 +-
.../test_dml_stream_load_be_auth_docker.groovy | 321 +++++
.../suites/cloud_p0/s3/test_s3_rate_limiter.groovy | 388 ++++++
.../test_s3_rate_limiter_cgroup_cpu_resize.groovy | 116 ++
.../table_modify_resouce_and_policy.groovy | 43 +-
.../table_modify_resouce_and_policy_by_hdfs.groovy | 43 +-
.../compaction_width_array_column.groovy | 7 +-
.../suites/compaction/ddl/column_witdh_array.sql | 5 +-
.../test_group_by_fixed_width_struct.groovy | 76 ++
.../test_timestamptz_struct_insert.groovy | 35 +-
.../iceberg_and_internal_nested_namespace.groovy | 66 +-
.../test_iceberg_arrow_flight_split_source.groovy | 131 ++
...rg_write_merge_duplicate_source_negative.groovy | 73 +-
.../lance/test_lance_vector_search.groovy | 48 +-
.../test_lance_vector_search_element_types.groovy | 124 ++
.../test_lance_vector_search_index_types.groovy | 184 +++
.../lance/test_lance_vector_search_ivf_flat.groovy | 163 +++
.../test_lance_vector_search_two_phase.groovy | 210 ++++
.../paimon/test_paimon_write_boundary.groovy | 37 +-
.../test_variant_typed_path_bloom_filter.groovy | 64 +
.../suites/inverted_index_p2/test_show_data.groovy | 8 +-
.../test_routine_load_adaptive_param.groovy | 16 +-
.../infer_set_operator_distinct.groovy | 360 ------
.../test_paimon_write_row_level_dml.groovy | 663 +++++++++++
.../suites/show_p0/test_show_tablet.groovy | 69 ++
.../tpch_sf100_unique_mor_p2/ddl/customer.sql | 17 +
.../tpch_sf100_unique_mor_p2/ddl/customer_dup.sql | 16 +
.../ddl/customer_dup_load.sql | 6 +
.../ddl/customer_load.sql | 0
.../tpch_sf100_unique_mor_p2/ddl/lineitem.sql | 25 +
.../tpch_sf100_unique_mor_p2/ddl/lineitem_dup.sql | 24 +
.../ddl/lineitem_dup_load.sql | 6 +
.../tpch_sf100_unique_mor_p2/ddl/lineitem_load.sql | 6 +
.../suites/tpch_sf100_unique_mor_p2/ddl/nation.sql | 13 +
.../tpch_sf100_unique_mor_p2/ddl/nation_dup.sql | 12 +
.../ddl/nation_dup_load.sql | 6 +
.../ddl/nation_load.sql | 0
.../suites/tpch_sf100_unique_mor_p2/ddl/orders.sql | 18 +
.../tpch_sf100_unique_mor_p2/ddl/orders_dup.sql | 17 +
.../ddl/orders_dup_load.sql | 6 +
.../tpch_sf100_unique_mor_p2/ddl/orders_load.sql | 6 +
.../suites/tpch_sf100_unique_mor_p2/ddl/part.sql | 18 +
.../tpch_sf100_unique_mor_p2/ddl/part_dup.sql | 17 +
.../tpch_sf100_unique_mor_p2/ddl/part_dup_load.sql | 6 +
.../ddl/part_load.sql | 0
.../tpch_sf100_unique_mor_p2/ddl/partsupp.sql | 14 +
.../tpch_sf100_unique_mor_p2/ddl/partsupp_dup.sql | 13 +
.../ddl/partsupp_dup_load.sql | 6 +
.../tpch_sf100_unique_mor_p2/ddl/partsupp_load.sql | 6 +
.../suites/tpch_sf100_unique_mor_p2/ddl/region.sql | 12 +
.../tpch_sf100_unique_mor_p2/ddl/region_dup.sql | 11 +
.../ddl/region_dup_load.sql | 6 +
.../ddl/region_load.sql | 0
.../tpch_sf100_unique_mor_p2/ddl/supplier.sql | 16 +
.../tpch_sf100_unique_mor_p2/ddl/supplier_dup.sql | 15 +
.../ddl/supplier_dup_load.sql | 6 +
.../ddl/supplier_load.sql | 0
.../suites/tpch_sf100_unique_mor_p2/load.groovy | 97 ++
.../sql/q01.sql | 0
.../sql/q02.sql | 0
.../sql/q03.sql | 0
.../sql/q04.sql | 0
.../sql/q05.sql | 0
.../sql/q06.sql | 0
.../sql/q07.sql | 0
.../sql/q08.sql | 0
.../sql/q09.sql | 0
.../sql/q10.sql | 0
.../sql/q11.sql | 0
.../sql/q12.sql | 0
.../sql/q13.sql | 0
.../sql/q14.sql | 0
.../sql/q15.sql | 0
.../sql/q16.sql | 0
.../sql/q17.sql | 0
.../sql/q18.sql | 0
.../sql/q19.sql | 0
.../sql/q20.sql | 0
.../sql/q21.sql | 0
.../sql/q22.sql | 0
.../test_mor_value_predicate_pushdown.groovy | 49 +
.../test_read_mor_as_dup.groovy | 56 +
thirdparty/download-thirdparty.sh | 13 +
thirdparty/patches/lance-c-0.1.6-doris.patch | 632 ++++++++++
472 files changed, 23843 insertions(+), 3925 deletions(-)
create mode 100644 be/src/format_v2/file_scan_context.h
create mode 100644 be/src/io/fs/rate_limited_obj_storage_client.cpp
create mode 100644 be/src/io/fs/rate_limited_obj_storage_client.h
create mode 100644 be/src/util/s3_rate_limiter_manager.cpp
create mode 100644 be/src/util/s3_rate_limiter_manager.h
create mode 100644 be/test/exec/common/hash_table/hash_key_type_test.cpp
create mode 100644 be/test/io/fs/rate_limited_obj_storage_client_test.cpp
create mode 100644 be/test/util/s3_rate_limiter_manager_test.cpp
rename
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/{c325fd55_doris$vs_ivf_pq_f32/_indices/4231299b-169a-4694-b440-7fb7396b1188
=>
3adf6edd_doris$vs_ivf_pq_f32/_indices/f7df7f0a-77f9-428a-abe2-fe510132cfa0}/auxiliary.idx
(68%)
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/3adf6edd_doris$vs_ivf_pq_f32/_indices/f7df7f0a-77f9-428a-abe2-fe510132cfa0/index.idx
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/3adf6edd_doris$vs_ivf_pq_f32/_transactions/0-3905e742-2db0-44e1-ad56-cd0b159e6799.txn
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/3adf6edd_doris$vs_ivf_pq_f32/_transactions/1-1d77fd49-8d7b-44ac-98ea-062ed07cdc55.txn
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/3adf6edd_doris$vs_ivf_pq_f32/_transactions/2-28c146c4-c5bb-4a77-aa56-69f44b86554e.txn
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/3adf6edd_doris$vs_ivf_pq_f32/_versions/18446744073709551612.manifest
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/3adf6edd_doris$vs_ivf_pq_f32/_versions/18446744073709551613.manifest
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/3adf6edd_doris$vs_ivf_pq_f32/_versions/18446744073709551614.manifest
copy
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/{c325fd55_doris$vs_ivf_pq_f32/data/1110011011101111011010118622b246be93248675bfdaadfa.lance
=>
3adf6edd_doris$vs_ivf_pq_f32/data/010000001110110001100111d378864dcfa9a71f2b65502410.lance}
(100%)
copy
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/{c325fd55_doris$vs_ivf_pq_f32/data/111110100011100011000111e29e464c90b09bf330ca3b02c2.lance
=>
3adf6edd_doris$vs_ivf_pq_f32/data/010110101011010011110010a6cc2f4eaa978e7269ec893256.lance}
(100%)
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/5b3f9aa6_doris$vs_ivf_sq_f32/_indices/b86c8bbc-8246-40ec-add8-541c0767bbd1/auxiliary.idx
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/5b3f9aa6_doris$vs_ivf_sq_f32/_indices/b86c8bbc-8246-40ec-add8-541c0767bbd1/index.idx
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/5b3f9aa6_doris$vs_ivf_sq_f32/_transactions/0-c6c7f7b9-4e6c-47cd-a4e6-d1ccdf906f8f.txn
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/5b3f9aa6_doris$vs_ivf_sq_f32/_transactions/1-7f715afd-47f2-4bbb-8117-98f5c83101c5.txn
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/5b3f9aa6_doris$vs_ivf_sq_f32/_transactions/2-d8509420-ada7-4ef3-9349-38b10e05e986.txn
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/5b3f9aa6_doris$vs_ivf_sq_f32/_versions/18446744073709551612.manifest
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/5b3f9aa6_doris$vs_ivf_sq_f32/_versions/18446744073709551613.manifest
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/5b3f9aa6_doris$vs_ivf_sq_f32/_versions/18446744073709551614.manifest
copy
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/{c325fd55_doris$vs_ivf_pq_f32/data/1110011011101111011010118622b246be93248675bfdaadfa.lance
=>
5b3f9aa6_doris$vs_ivf_sq_f32/data/011100001101011010111011e4196f4fb2af4e34597f44de02.lance}
(100%)
copy
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/{c325fd55_doris$vs_ivf_pq_f32/data/111110100011100011000111e29e464c90b09bf330ca3b02c2.lance
=>
5b3f9aa6_doris$vs_ivf_sq_f32/data/011101011001000010010101891e4943169d6a864e75c5188f.lance}
(100%)
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/7cfee6da_doris$vs_ivf_hnsw_pq_f32/_indices/fd49bcd3-69f4-49a1-b243-f2218af4d90d/auxiliary.idx
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/7cfee6da_doris$vs_ivf_hnsw_pq_f32/_indices/fd49bcd3-69f4-49a1-b243-f2218af4d90d/index.idx
copy
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/{c325fd55_doris$vs_ivf_pq_f32/_transactions/0-c618efe7-b762-45a3-9600-02e54c17cf87.txn
=>
7cfee6da_doris$vs_ivf_hnsw_pq_f32/_transactions/0-26573fb0-fe5f-42a5-923d-676a5a48867d.txn}
(60%)
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/7cfee6da_doris$vs_ivf_hnsw_pq_f32/_transactions/1-e02edfb0-0b30-4f00-8d65-5256646feafa.txn
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/7cfee6da_doris$vs_ivf_hnsw_pq_f32/_transactions/2-0de2b847-e8da-433e-b198-67eec67a9b40.txn
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/7cfee6da_doris$vs_ivf_hnsw_pq_f32/_versions/18446744073709551612.manifest
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/7cfee6da_doris$vs_ivf_hnsw_pq_f32/_versions/18446744073709551613.manifest
copy
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/{c325fd55_doris$vs_ivf_pq_f32
=> 7cfee6da_doris$vs_ivf_hnsw_pq_f32}/_versions/18446744073709551614.manifest
(53%)
copy
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/{c325fd55_doris$vs_ivf_pq_f32/data/111110100011100011000111e29e464c90b09bf330ca3b02c2.lance
=>
7cfee6da_doris$vs_ivf_hnsw_pq_f32/data/110110011111101010111100a6c4c14e0f8c1945b7745a4f53.lance}
(100%)
copy
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/{c325fd55_doris$vs_ivf_pq_f32/data/1110011011101111011010118622b246be93248675bfdaadfa.lance
=>
7cfee6da_doris$vs_ivf_hnsw_pq_f32/data/11101101000100000101101059dd5a4247a3c800111e04933f.lance}
(100%)
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/86676f94_doris$vs_ivf_flat_f32/_indices/b3fe52ad-845e-4174-9460-adc004837420/auxiliary.idx
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/86676f94_doris$vs_ivf_flat_f32/_indices/b3fe52ad-845e-4174-9460-adc004837420/index.idx
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/86676f94_doris$vs_ivf_flat_f32/_transactions/0-16aff25d-10f6-4ab9-8683-bc1cff3c9654.txn
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/86676f94_doris$vs_ivf_flat_f32/_transactions/1-96659ad8-de9d-40bb-84bc-96155bc2e04c.txn
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/86676f94_doris$vs_ivf_flat_f32/_transactions/2-42fa5fcb-4bf6-415d-9fb0-2573219e15c5.txn
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/86676f94_doris$vs_ivf_flat_f32/_versions/18446744073709551612.manifest
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/86676f94_doris$vs_ivf_flat_f32/_versions/18446744073709551613.manifest
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/86676f94_doris$vs_ivf_flat_f32/_versions/18446744073709551614.manifest
copy
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/{c325fd55_doris$vs_ivf_pq_f32/data/111110100011100011000111e29e464c90b09bf330ca3b02c2.lance
=>
86676f94_doris$vs_ivf_flat_f32/data/10111100010101000101000036753c4e35998eee5f926e7181.lance}
(100%)
copy
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/{c325fd55_doris$vs_ivf_pq_f32/data/1110011011101111011010118622b246be93248675bfdaadfa.lance
=>
86676f94_doris$vs_ivf_flat_f32/data/111001110100110110110101c621e94ffe9ee5013b3c26331f.lance}
(100%)
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/__manifest/_indices/259cbf62-5bca-412b-a4d7-8bd6b75bd7f2/page_data.lance
rename
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/__manifest/_indices/{6ac57aba-0a7a-4303-ba43-c61610e205b9
=> 259cbf62-5bca-412b-a4d7-8bd6b75bd7f2}/page_lookup.lance (89%)
delete mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/__manifest/_indices/6ac57aba-0a7a-4303-ba43-c61610e205b9/page_data.lance
rename
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/__manifest/_indices/{1f436c06-a392-4c38-af67-d10bef96f82f
=> 70cf4b86-c98e-41c8-99b3-9e275524bb75}/bitmap_page_lookup.lance (60%)
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/__manifest/_indices/8bd6fdb0-4402-415a-bf72-8c8b072e3030/bitmap_page_lookup.lance
delete mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/__manifest/_indices/be88a0b2-a11c-4537-b8eb-120ad3c24380/bitmap_page_lookup.lance
delete mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/__manifest/_transactions/14-2b2b0055-53cb-4e2e-a2d8-c17bb410ce79.txn
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/__manifest/_transactions/34-68394369-30e4-4ffa-b61e-197dc759bdb5.txn
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/__manifest/_versions/18446744073709551580.manifest
delete mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/__manifest/_versions/18446744073709551600.manifest
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/__manifest/data/10110010111110111000110083a5334199aea08c5eacc59581.lance
delete mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/__manifest/data/1011101111101100100100100a8e404e57ae0aa8a08e98d5ec.lance
delete mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/c325fd55_doris$vs_ivf_pq_f32/_indices/4231299b-169a-4694-b440-7fb7396b1188/index.idx
delete mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/c325fd55_doris$vs_ivf_pq_f32/_transactions/1-050f2e5b-6487-4532-b15a-8200a82dc87b.txn
delete mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/c325fd55_doris$vs_ivf_pq_f32/_transactions/2-8b309f5c-51bc-414c-98cf-dcc867178c25.txn
delete mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/c325fd55_doris$vs_ivf_pq_f32/_versions/18446744073709551612.manifest
delete mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/c325fd55_doris$vs_ivf_pq_f32/_versions/18446744073709551613.manifest
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/ce0c2a78_doris$vs_ivf_hnsw_flat_f32/_indices/a4a12893-4aa7-4146-89a0-c14ff214fcdf/auxiliary.idx
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/ce0c2a78_doris$vs_ivf_hnsw_flat_f32/_indices/a4a12893-4aa7-4146-89a0-c14ff214fcdf/index.idx
rename
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/{c325fd55_doris$vs_ivf_pq_f32/_transactions/0-c618efe7-b762-45a3-9600-02e54c17cf87.txn
=>
ce0c2a78_doris$vs_ivf_hnsw_flat_f32/_transactions/0-fba03dae-4bc9-46cc-88e1-48d12334d9c8.txn}
(60%)
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/ce0c2a78_doris$vs_ivf_hnsw_flat_f32/_transactions/1-b7e0b480-e85b-4b2d-b640-db1e83fe0ec0.txn
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/ce0c2a78_doris$vs_ivf_hnsw_flat_f32/_transactions/2-7cd05522-1faf-4bb3-b858-dbe3bb66f5dd.txn
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/ce0c2a78_doris$vs_ivf_hnsw_flat_f32/_versions/18446744073709551612.manifest
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/ce0c2a78_doris$vs_ivf_hnsw_flat_f32/_versions/18446744073709551613.manifest
rename
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/{c325fd55_doris$vs_ivf_pq_f32
=>
ce0c2a78_doris$vs_ivf_hnsw_flat_f32}/_versions/18446744073709551614.manifest
(60%)
copy
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/{c325fd55_doris$vs_ivf_pq_f32/data/1110011011101111011010118622b246be93248675bfdaadfa.lance
=>
ce0c2a78_doris$vs_ivf_hnsw_flat_f32/data/110010101101110011000011fbb8834dbeb678db4c956aa2dc.lance}
(100%)
copy
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/{c325fd55_doris$vs_ivf_pq_f32/data/111110100011100011000111e29e464c90b09bf330ca3b02c2.lance
=>
ce0c2a78_doris$vs_ivf_hnsw_flat_f32/data/111110111110010101000100270fdd4ff3a7fca1d1b7edc733.lance}
(100%)
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/d4fc3972_doris$vs_ivf_hnsw_sq_f32/_indices/89f3af0e-9900-457b-90de-840d10411bc9/auxiliary.idx
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/d4fc3972_doris$vs_ivf_hnsw_sq_f32/_indices/89f3af0e-9900-457b-90de-840d10411bc9/index.idx
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/d4fc3972_doris$vs_ivf_hnsw_sq_f32/_transactions/0-f4895c26-f312-4756-9770-212b6729b540.txn
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/d4fc3972_doris$vs_ivf_hnsw_sq_f32/_transactions/1-07a3d515-bca1-4363-85b9-493ffcd96d06.txn
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/d4fc3972_doris$vs_ivf_hnsw_sq_f32/_transactions/2-352ecaa2-290a-4dd6-a2c2-796c46d9f195.txn
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/d4fc3972_doris$vs_ivf_hnsw_sq_f32/_versions/18446744073709551612.manifest
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/d4fc3972_doris$vs_ivf_hnsw_sq_f32/_versions/18446744073709551613.manifest
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/d4fc3972_doris$vs_ivf_hnsw_sq_f32/_versions/18446744073709551614.manifest
rename
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/{c325fd55_doris$vs_ivf_pq_f32/data/1110011011101111011010118622b246be93248675bfdaadfa.lance
=>
d4fc3972_doris$vs_ivf_hnsw_sq_f32/data/000001100000100001110000e1645442cbb94bb40a5df3a0ae.lance}
(100%)
rename
docker/thirdparties/docker-compose/iceberg/scripts/preinstalled_data/lance/{c325fd55_doris$vs_ivf_pq_f32/data/111110100011100011000111e29e464c90b09bf330ca3b02c2.lance
=>
d4fc3972_doris$vs_ivf_hnsw_sq_f32/data/00100000001101010110000165e42c4182a64dc3e8b72990fe.lance}
(100%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/common/util/SortAndLimit.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/common/util/ThriftLogHelper.java
copy be/test/exec/sink/writer/paimon/paimon_write_backend_test.cpp =>
fe/fe-core/src/main/java/org/apache/doris/datasource/ExternalScanTaskCacheKey.java
(63%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/lance/LanceFragmentInfo.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/lance/LanceIndexSegmentInfo.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/lance/source/IndexSegmentSplitPlan.java
copy be/test/exec/sink/writer/paimon/paimon_write_backend_test.cpp =>
fe/fe-core/src/main/java/org/apache/doris/datasource/paimon/PaimonRowChangeOperation.java
(63%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/analysis/PaimonMergePlanner.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/analysis/PaimonRowChangeCapabilities.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/analysis/PaimonRowChangePlanBuilder.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/PushDownFilterThroughVectorSearchTopN.java
copy be/test/exec/sink/writer/paimon/paimon_write_backend_test.cpp =>
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/AlwaysShortCircuit.java
(63%)
copy be/test/exec/sink/writer/paimon/paimon_write_backend_test.cpp =>
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/ShortCircuitIf.java
(50%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/PaimonDeleteCommand.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/PaimonMergeCommand.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/PaimonUpdateCommand.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/info/PaimonRowChangeSpec.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/cloud/load/CloudBrokerLoadJobTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/cloud/snapshot/CloudSnapshotHandlerTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/common/util/SortAndLimitTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/common/util/ThriftLogHelperTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/hudi/source/HudiScanNodeTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/kafka/KafkaUtilTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/job/executor/TaskProcessorTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/processor/post/materialize/MaterializeProbeVisitorTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/rules/rewrite/InferSetOperatorDistinctTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/service/arrowflight/sessions/FlightSqlConnectPoolMgrTest.java
create mode 100644 regression-test/data/cloud_p0/s3/test_s3_rate_limiter.out
create mode 100644
regression-test/data/datatype_p0/complex_types/test_group_by_fixed_width_struct.out
create mode 100644
regression-test/data/datatype_p0/timestamptz/test_timestamptz_struct_insert.out
create mode 100644
regression-test/data/external_table_p0/lance/test_lance_vector_search_element_types.out
create mode 100644
regression-test/data/external_table_p0/lance/test_lance_vector_search_index_types.out
copy
regression-test/data/external_table_p0/lance/{test_lance_vector_search.out =>
test_lance_vector_search_ivf_flat.out} (81%)
create mode 100644
regression-test/data/external_table_p0/lance/test_lance_vector_search_two_phase.out
delete mode 100644
regression-test/data/nereids_rules_p0/infer_set_operator_distinct/infer_set_operator_distinct.out
create mode 100644
regression-test/data/paimon_write/test_paimon_write_row_level_dml.out
copy regression-test/data/{tpch_sf100_p2 =>
tpch_sf100_unique_mor_p2}/sql/q01.out (100%)
copy regression-test/data/{tpch_sf100_p2 =>
tpch_sf100_unique_mor_p2}/sql/q02.out (100%)
copy regression-test/data/{tpch_sf100_p2 =>
tpch_sf100_unique_mor_p2}/sql/q03.out (100%)
copy regression-test/data/{tpch_sf100_p2 =>
tpch_sf100_unique_mor_p2}/sql/q04.out (100%)
copy regression-test/data/{tpch_sf100_p2 =>
tpch_sf100_unique_mor_p2}/sql/q05.out (100%)
copy regression-test/data/{tpch_sf100_p2 =>
tpch_sf100_unique_mor_p2}/sql/q06.out (100%)
copy regression-test/data/{tpch_sf100_p2 =>
tpch_sf100_unique_mor_p2}/sql/q07.out (100%)
copy regression-test/data/{tpch_sf100_p2 =>
tpch_sf100_unique_mor_p2}/sql/q08.out (100%)
copy regression-test/data/{tpch_sf100_p2 =>
tpch_sf100_unique_mor_p2}/sql/q09.out (100%)
copy regression-test/data/{tpch_sf100_p2 =>
tpch_sf100_unique_mor_p2}/sql/q10.out (100%)
copy regression-test/data/{tpch_sf100_p2 =>
tpch_sf100_unique_mor_p2}/sql/q11.out (100%)
copy regression-test/data/{tpch_sf100_p2 =>
tpch_sf100_unique_mor_p2}/sql/q12.out (100%)
copy regression-test/data/{tpch_sf100_p2 =>
tpch_sf100_unique_mor_p2}/sql/q13.out (100%)
copy regression-test/data/{tpch_sf100_p2 =>
tpch_sf100_unique_mor_p2}/sql/q14.out (100%)
copy regression-test/data/{tpch_sf100_p2 =>
tpch_sf100_unique_mor_p2}/sql/q15.out (100%)
copy regression-test/data/{tpch_sf100_p2 =>
tpch_sf100_unique_mor_p2}/sql/q16.out (100%)
copy regression-test/data/{tpch_sf100_p2 =>
tpch_sf100_unique_mor_p2}/sql/q17.out (100%)
copy regression-test/data/{tpch_sf100_p2 =>
tpch_sf100_unique_mor_p2}/sql/q18.out (100%)
copy regression-test/data/{tpch_sf100_p2 =>
tpch_sf100_unique_mor_p2}/sql/q19.out (100%)
copy regression-test/data/{tpch_sf100_p2 =>
tpch_sf100_unique_mor_p2}/sql/q20.out (100%)
copy regression-test/data/{tpch_sf100_p2 =>
tpch_sf100_unique_mor_p2}/sql/q21.out (100%)
copy regression-test/data/{tpch_sf100_p2 =>
tpch_sf100_unique_mor_p2}/sql/q22.out (100%)
create mode 100644
regression-test/suites/auth_call/test_dml_stream_load_be_auth_docker.groovy
create mode 100644
regression-test/suites/cloud_p0/s3/test_s3_rate_limiter.groovy
create mode 100644
regression-test/suites/cloud_p0/s3/test_s3_rate_limiter_cgroup_cpu_resize.groovy
create mode 100644
regression-test/suites/datatype_p0/complex_types/test_group_by_fixed_width_struct.groovy
copy be/test/exec/sink/writer/paimon/paimon_write_backend_test.cpp =>
regression-test/suites/datatype_p0/timestamptz/test_timestamptz_struct_insert.groovy
(51%)
create mode 100644
regression-test/suites/external_table_p0/iceberg/test_iceberg_arrow_flight_split_source.groovy
create mode 100644
regression-test/suites/external_table_p0/lance/test_lance_vector_search_element_types.groovy
create mode 100644
regression-test/suites/external_table_p0/lance/test_lance_vector_search_index_types.groovy
create mode 100644
regression-test/suites/external_table_p0/lance/test_lance_vector_search_ivf_flat.groovy
create mode 100644
regression-test/suites/external_table_p0/lance/test_lance_vector_search_two_phase.groovy
create mode 100644
regression-test/suites/fault_injection_p0/test_variant_typed_path_bloom_filter.groovy
delete mode 100644
regression-test/suites/nereids_rules_p0/infer_set_operator_distinct/infer_set_operator_distinct.groovy
create mode 100644
regression-test/suites/paimon_write/test_paimon_write_row_level_dml.groovy
create mode 100644
regression-test/suites/tpch_sf100_unique_mor_p2/ddl/customer.sql
create mode 100644
regression-test/suites/tpch_sf100_unique_mor_p2/ddl/customer_dup.sql
create mode 100644
regression-test/suites/tpch_sf100_unique_mor_p2/ddl/customer_dup_load.sql
copy regression-test/suites/{cloud_p0/cache/multi_cluster/read_write =>
tpch_sf100_unique_mor_p2}/ddl/customer_load.sql (100%)
create mode 100644
regression-test/suites/tpch_sf100_unique_mor_p2/ddl/lineitem.sql
create mode 100644
regression-test/suites/tpch_sf100_unique_mor_p2/ddl/lineitem_dup.sql
create mode 100644
regression-test/suites/tpch_sf100_unique_mor_p2/ddl/lineitem_dup_load.sql
create mode 100644
regression-test/suites/tpch_sf100_unique_mor_p2/ddl/lineitem_load.sql
create mode 100644
regression-test/suites/tpch_sf100_unique_mor_p2/ddl/nation.sql
create mode 100644
regression-test/suites/tpch_sf100_unique_mor_p2/ddl/nation_dup.sql
create mode 100644
regression-test/suites/tpch_sf100_unique_mor_p2/ddl/nation_dup_load.sql
copy regression-test/suites/{cloud_p0/multi_cluster/multi_cluster_s3_load =>
tpch_sf100_unique_mor_p2}/ddl/nation_load.sql (100%)
create mode 100644
regression-test/suites/tpch_sf100_unique_mor_p2/ddl/orders.sql
create mode 100644
regression-test/suites/tpch_sf100_unique_mor_p2/ddl/orders_dup.sql
create mode 100644
regression-test/suites/tpch_sf100_unique_mor_p2/ddl/orders_dup_load.sql
create mode 100644
regression-test/suites/tpch_sf100_unique_mor_p2/ddl/orders_load.sql
create mode 100644 regression-test/suites/tpch_sf100_unique_mor_p2/ddl/part.sql
create mode 100644
regression-test/suites/tpch_sf100_unique_mor_p2/ddl/part_dup.sql
create mode 100644
regression-test/suites/tpch_sf100_unique_mor_p2/ddl/part_dup_load.sql
copy regression-test/suites/{cloud_p0/multi_cluster/multi_cluster_s3_load =>
tpch_sf100_unique_mor_p2}/ddl/part_load.sql (100%)
create mode 100644
regression-test/suites/tpch_sf100_unique_mor_p2/ddl/partsupp.sql
create mode 100644
regression-test/suites/tpch_sf100_unique_mor_p2/ddl/partsupp_dup.sql
create mode 100644
regression-test/suites/tpch_sf100_unique_mor_p2/ddl/partsupp_dup_load.sql
create mode 100644
regression-test/suites/tpch_sf100_unique_mor_p2/ddl/partsupp_load.sql
create mode 100644
regression-test/suites/tpch_sf100_unique_mor_p2/ddl/region.sql
create mode 100644
regression-test/suites/tpch_sf100_unique_mor_p2/ddl/region_dup.sql
create mode 100644
regression-test/suites/tpch_sf100_unique_mor_p2/ddl/region_dup_load.sql
copy regression-test/suites/{cloud_p0/multi_cluster/multi_cluster_s3_load =>
tpch_sf100_unique_mor_p2}/ddl/region_load.sql (100%)
create mode 100644
regression-test/suites/tpch_sf100_unique_mor_p2/ddl/supplier.sql
create mode 100644
regression-test/suites/tpch_sf100_unique_mor_p2/ddl/supplier_dup.sql
create mode 100644
regression-test/suites/tpch_sf100_unique_mor_p2/ddl/supplier_dup_load.sql
copy regression-test/suites/{cloud_p0/multi_cluster/multi_cluster_s3_load =>
tpch_sf100_unique_mor_p2}/ddl/supplier_load.sql (100%)
create mode 100644 regression-test/suites/tpch_sf100_unique_mor_p2/load.groovy
copy regression-test/suites/{tpch_sf100_unique_sql_p2 =>
tpch_sf100_unique_mor_p2}/sql/q01.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
tpch_sf100_unique_mor_p2}/sql/q02.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
tpch_sf100_unique_mor_p2}/sql/q03.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
tpch_sf100_unique_mor_p2}/sql/q04.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
tpch_sf100_unique_mor_p2}/sql/q05.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
tpch_sf100_unique_mor_p2}/sql/q06.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
tpch_sf100_unique_mor_p2}/sql/q07.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
tpch_sf100_unique_mor_p2}/sql/q08.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
tpch_sf100_unique_mor_p2}/sql/q09.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
tpch_sf100_unique_mor_p2}/sql/q10.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
tpch_sf100_unique_mor_p2}/sql/q11.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
tpch_sf100_unique_mor_p2}/sql/q12.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
tpch_sf100_unique_mor_p2}/sql/q13.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
tpch_sf100_unique_mor_p2}/sql/q14.sql (100%)
copy regression-test/suites/{tpch_sf100_p2 =>
tpch_sf100_unique_mor_p2}/sql/q15.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
tpch_sf100_unique_mor_p2}/sql/q16.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
tpch_sf100_unique_mor_p2}/sql/q17.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
tpch_sf100_unique_mor_p2}/sql/q18.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
tpch_sf100_unique_mor_p2}/sql/q19.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
tpch_sf100_unique_mor_p2}/sql/q20.sql (100%)
copy regression-test/suites/{tpch_sf100_unique_sql_p2 =>
tpch_sf100_unique_mor_p2}/sql/q21.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
tpch_sf100_unique_mor_p2}/sql/q22.sql (100%)
create mode 100644
regression-test/suites/tpch_sf100_unique_mor_p2/test_mor_value_predicate_pushdown.groovy
create mode 100644
regression-test/suites/tpch_sf100_unique_mor_p2/test_read_mor_as_dup.groovy
create mode 100644 thirdparty/patches/lance-c-0.1.6-doris.patch
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
