This is an automated email from the ASF dual-hosted git repository.
morningman pushed a change to branch branch-catalog-spi
in repository https://gitbox.apache.org/repos/asf/doris.git
discard a653478cb2e [fix](catalog) jdbc: keep driver classloaders alive per
URL to stop Metaspace leak
omit 8b391c7459d [refactor](catalog) P6 iceberg: migrate to catalog SPI +
cutover + remove legacy fe-core subsystem (#64688)
omit 494ec177d58 [refactor](catalog) P3b: consolidate kerberos
authentication into fe-kerberos (#64655)
omit 34f1eb723d8 [refactor](catalog) P5 paimon: remove legacy subsystem
from fe-core + make fe-core paimon-SDK-free (T29) (#64653)
omit a26eaeff84c [refactor](catalog) P5 paimon: migrate to catalog SPI +
cutover (#64446) (#64446)
omit 741d70582c0 update P5 handoff and fix compile issue
omit f6b4d562255 [refactor](connector) P4 maxcompute: remove legacy
subsystem from fe-core + make fe-core odps-free (T07-T09) (#64300)
omit 875e8c51f5f [feat](connector) P3 hudi connector hardening + test
baseline + dispatch design (hybrid, T02-T08) (#64143)
omit 533dfbf9e5e [feat](connector) P2 migrate trino-connector to catalog
SPI (T01-T13) (#64096)
omit a58c891d838 [P1-T03-T05] route plugin-driven scans first in nereids
translator (#63641)
omit 878806ac287 [feat](connector) P0 SPI baseline + DDL/Partition + import
gate (T03-T27) (#63582)
omit b6ec2e37f29 [doc](connector) add project tracking system for catalog
SPI migration
add 7bfda3179b6 [fix](be) Fix null query crash in inverted index
predicates (#65138)
add 3f57f8e8341 [test](regression) Update HDFS parquet group4 output
(#65194)
add e2bfaa807f0 [fix](regression) Batch export_p0 generated VALUES inserts
(#65208)
add 49e888e2450 [fix](streaming-job) Support delete sign in CDC stream TVF
(#65146)
add 5c7110b978c [fix](glue) cache credentials provider in
ConfigurationAWSCredentialsProvider (#65165)
add f401ccb56de [refine](pipeline) Add exchange source debug details
(#65167)
add fcffadcb67c [fix](orc) decode timestamp through serde (#64854)
add 0b6a20f458e [feat](dynamic table) support table stream part 4:
support snapshot read (#64776)
add 9561ad9e8c9 [fix](fe) Parse MaxCompute partition specs by name (#64937)
add 1866967e048 [fix](regression) Adjust large TTL cache regression case
(#64789)
add 122f3b0d8f1 [fix](orc)fix hive-orc reader read columns base in column
index by default rather than column name. (#65085)
add 0c8ee958394 [fix](fe) Fix show data all result row width (#65215)
add 6c6b72924b2 [fix](maxcompute)Fix MaxCompute IN predicate pushdown
polarity. (#65083)
add 9012d3bd6f3 [fix](regression) handle E-2010 compaction success wait
(#65209)
add 61920b70576 [fix](regression) wait for adaptive scan profile (#64923)
add cad35a6d73f [codex] Add CODEOWNERS for airborne12-owned paths (#65239)
add 056acbeac2f [fix](regression) stabilize index change wait (#65197)
add d1bcea2962c [fix](fe) Stabilize RollupJobV2Test task execution (#65204)
add 8ea88fcede6 [fix](regression) Disable auto compaction in manual
compaction cases (#65211)
add dd487dbde57 [fix](regression) force cleanup routine load error info
tables (#65214)
add de5ce1f6594 [fix](be) Use VExpr for file scanner v2 ZoneMap pruning
(#65175)
add dc70115a432 [Enhancement](BE) Make print stack API more stable (#64093)
add 70bd2ec64a7 [improvement](be) Hoist aggregate column type checks
(#65031)
add e1c0e310a43 [test](case) add some log in test case (#65236)
add 9fc6513ac05 (fix)(eager-agg) null-to-non-null safety check and remove
redundant normalize calls in eager aggregation (#64820)
add 49af19213e7 [fix](transaction) avoid aborting newer same-label
transactions (#64939)
add c09ebd73c13 [test](regression) Remove parquet complex cross page case
(#65251)
add d72635e919b [chore](tde) Add scoped KMS credentials to regression
clusters (#64564)
add 06ea5bdd95d [fix](fe) Skip decommissioning BE for load (#65049)
add f7671a0f331 [fix](regression) fix test_fe_cached_partition_version
(#65158)
add d1d8b29790c [feature](tools) Add fast-fe-ut.sh for fast incremental FE
unit test running (#65055)
add 058dfd3794a [opt](schema) Optimize tables schema scan status (#64933)
add f45888fe98b [improvement](topn) Add option to skip file cache writes
in topn lazy materialization (#65021)
add 8cf30aa0a17 [fix](fe) Prevent pushing other join conditions to right
child of null-aware anti join (#64898)
add 6c86c91bb84 [bug](analytic) fix partition by column when it overflow
haven't convert to column64 (#65240)
add cfb407107a5 [feature](load) introduce adaptive random bucket load
routing (#62661)
add 5e1c5427b3e [chore](broker)(sdk) Remove apache_hdfs_broker daemon
module and in-tree SDKs (#64732)
add 2eaf314fc0d [fix](be) Rework FileScannerV2 scan accounting and stop
handling (#65218)
add 2a54405ca67 [fix](show frontends) show effective HTTP/HTTPS port
(#64670)
add 553c23dd340 [fix](regression) Use local HTTP resources in TVF test
(#65299)
add 00d9601f3e0 [doc](connector) add project tracking system for catalog
SPI migration
add 4c1c8f2273e [feat](connector) P0 SPI baseline + DDL/Partition + import
gate (T03-T27) (#63582)
add 1ee2a9c3b09 [P1-T03-T05] route plugin-driven scans first in nereids
translator (#63641)
add ec131c50d24 [feat](connector) P2 migrate trino-connector to catalog
SPI (T01-T13) (#64096)
add 41807d58df2 [feat](connector) P3 hudi connector hardening + test
baseline + dispatch design (hybrid, T02-T08) (#64143)
add 32a3b3a877c [refactor](connector) P4 maxcompute: remove legacy
subsystem from fe-core + make fe-core odps-free (T07-T09) (#64300)
add 07ec56a955b update P5 handoff and fix compile issue
add 64308c2581f [refactor](catalog) P5 paimon: migrate to catalog SPI +
cutover (#64446) (#64446)
add 67ca4f90c3b [refactor](catalog) P5 paimon: remove legacy subsystem
from fe-core + make fe-core paimon-SDK-free (T29) (#64653)
add a6c62e96006 [refactor](catalog) P3b: consolidate kerberos
authentication into fe-kerberos (#64655)
add 60433996726 [refactor](catalog) P6 iceberg: migrate to catalog SPI +
cutover + remove legacy fe-core subsystem (#64688)
add 34bd8eede75 [fix](catalog) jdbc: keep driver classloaders alive per
URL to stop Metaspace leak
add 3ba75b7cf8a [fix](catalog) P4 maxcompute: drop dangling legacy
MaxComputeExternalTableTest after rebase
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 (a653478cb2e)
\
N -- N -- N refs/heads/branch-catalog-spi (3ba75b7cf8a)
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:
.github/CODEOWNERS | 18 +-
.github/workflows/build-extension.yml | 39 -
.github/workflows/code-checks.yml | 2 +-
.gitignore | 3 -
be/CMakeLists.txt | 5 +-
be/src/cloud/cloud_delta_writer.cpp | 23 +-
be/src/cloud/cloud_delta_writer.h | 5 +-
be/src/cloud/cloud_meta_mgr.cpp | 7 +-
be/src/cloud/cloud_tablets_channel.cpp | 27 +
be/src/cloud/cloud_tablets_channel.h | 1 +
be/src/cloud/pb_convert.cpp | 12 +
be/src/common/config.cpp | 6 +-
be/src/common/config.h | 7 +-
be/src/common/phdr_cache.cpp | 237 +++-
be/src/common/phdr_cache.h | 59 +-
be/src/common/stack_trace.cpp | 16 +-
be/src/common/stack_trace.h | 5 +-
be/src/common/symbol_index.cpp | 230 ++-
be/src/core/column/column_string.cpp | 56 +-
.../data_type_serde/data_type_number_serde.cpp | 10 +-
be/src/core/data_type_serde/decoded_column_view.h | 5 +-
be/src/exec/operator/aggregation_sink_operator.cpp | 46 +-
.../exec/operator/aggregation_source_operator.cpp | 278 ++--
be/src/exec/operator/analytic_sink_operator.cpp | 39 +-
.../bucketed_aggregation_sink_operator.cpp | 11 +-
.../bucketed_aggregation_source_operator.cpp | 12 +-
be/src/exec/operator/exchange_source_operator.cpp | 51 +-
be/src/exec/operator/materialization_opertor.cpp | 209 ++-
be/src/exec/operator/materialization_opertor.h | 27 +-
be/src/exec/operator/olap_scan_operator.cpp | 21 +-
be/src/exec/operator/olap_scan_operator.h | 4 +
.../partitioned_aggregation_sink_operator.cpp | 17 +-
be/src/exec/operator/schema_scan_operator.cpp | 3 +
.../operator/streaming_aggregation_operator.cpp | 268 ++--
be/src/exec/pipeline/dependency.cpp | 4 +-
be/src/exec/rowid_fetcher.cpp | 74 +-
be/src/exec/rowid_fetcher.h | 19 +-
be/src/exec/scan/file_scanner_v2.cpp | 137 +-
be/src/exec/scan/file_scanner_v2.h | 27 +-
be/src/exec/scan/olap_scanner.cpp | 38 +-
be/src/exec/scan/olap_scanner.h | 3 +-
be/src/exec/sink/delta_writer_v2_pool.cpp | 1 +
be/src/exec/sink/vrow_distribution.cpp | 36 +-
be/src/exec/sink/vrow_distribution.h | 7 +-
be/src/exec/sink/vtablet_finder.cpp | 7 +-
be/src/exec/sink/vtablet_finder.h | 18 +-
be/src/exec/sink/writer/vtablet_writer.cpp | 267 +++-
be/src/exec/sink/writer/vtablet_writer.h | 24 +-
be/src/exec/sink/writer/vtablet_writer_v2.cpp | 27 +-
be/src/exprs/aggregate/aggregate_function.h | 52 +
be/src/exprs/aggregate/aggregate_function_ai_agg.h | 15 +-
.../aggregate_function_approx_count_distinct.h | 2 +-
.../exprs/aggregate/aggregate_function_array_agg.h | 67 +-
be/src/exprs/aggregate/aggregate_function_avg.h | 2 +-
.../aggregate/aggregate_function_avg_weighted.h | 7 +-
be/src/exprs/aggregate/aggregate_function_bit.h | 3 +-
be/src/exprs/aggregate/aggregate_function_bitmap.h | 30 +-
.../aggregate/aggregate_function_bitmap_agg.h | 12 +-
.../aggregate/aggregate_function_bool_union.h | 7 +-
.../exprs/aggregate/aggregate_function_collect.h | 46 +-
be/src/exprs/aggregate/aggregate_function_count.h | 18 +-
.../aggregate/aggregate_function_count_by_enum.h | 32 +-
be/src/exprs/aggregate/aggregate_function_covar.h | 4 +-
...aggregate_function_datasketches_hll_union_agg.h | 11 +-
be/src/exprs/aggregate/aggregate_function_ema.h | 9 +-
.../exprs/aggregate/aggregate_function_foreach.h | 42 +-
.../aggregate/aggregate_function_foreachv2.cpp | 8 +-
.../aggregate_function_group_array_set_op.h | 97 +-
.../aggregate/aggregate_function_group_concat.h | 13 +-
.../exprs/aggregate/aggregate_function_histogram.h | 26 +-
.../aggregate/aggregate_function_hll_union_agg.h | 4 +-
.../aggregate_function_linear_histogram.h | 17 +-
be/src/exprs/aggregate/aggregate_function_map.h | 17 +-
.../aggregate_function_map_combinator.cpp | 72 +-
be/src/exprs/aggregate/aggregate_function_map_v2.h | 5 +-
.../exprs/aggregate/aggregate_function_min_max.h | 53 +-
.../aggregate/aggregate_function_min_max_by.h | 4 +-
be/src/exprs/aggregate/aggregate_function_null.h | 66 +-
.../exprs/aggregate/aggregate_function_null_v2.h | 46 +-
.../aggregate_function_orthogonal_bitmap.h | 34 +-
.../aggregate/aggregate_function_percentile.h | 73 +-
.../aggregate_function_percentile_reservoir.h | 8 +-
.../exprs/aggregate/aggregate_function_product.h | 2 +-
.../aggregate/aggregate_function_quantile_state.h | 2 +-
.../aggregate_function_reader_first_last.h | 4 +-
.../aggregate_function_reader_replace.cpp | 2 +-
be/src/exprs/aggregate/aggregate_function_regr.h | 7 +-
.../exprs/aggregate/aggregate_function_retention.h | 10 +-
be/src/exprs/aggregate/aggregate_function_sem.h | 9 +-
.../aggregate/aggregate_function_sequence_match.h | 13 +-
be/src/exprs/aggregate/aggregate_function_sort.h | 9 +
.../exprs/aggregate/aggregate_function_statistic.h | 7 +-
be/src/exprs/aggregate/aggregate_function_stddev.h | 4 +-
be/src/exprs/aggregate/aggregate_function_sum.h | 2 +-
be/src/exprs/aggregate/aggregate_function_topn.h | 95 +-
be/src/exprs/aggregate/aggregate_function_uniq.h | 3 +-
.../aggregate_function_uniq_distribute_key.h | 3 +-
be/src/exprs/aggregate/aggregate_function_window.h | 23 +-
.../aggregate/aggregate_function_window_funnel.h | 24 +-
.../aggregate_function_window_funnel_v2.h | 29 +-
be/src/exprs/expr_zonemap_filter.cpp | 179 ++-
be/src/exprs/expr_zonemap_filter.h | 52 +
.../function/array/function_array_aggregation.cpp | 4 +
be/src/exprs/function/function.cpp | 10 +
be/src/exprs/function/function.h | 33 +
be/src/exprs/function/function_agg_state.h | 1 +
be/src/exprs/function/function_multi_match.cpp | 17 +-
be/src/exprs/function/functions_comparison.h | 44 +
be/src/exprs/function/match.cpp | 31 +-
be/src/exprs/function/match.h | 18 +-
be/src/exprs/vcompound_pred.h | 81 ++
be/src/exprs/vectorized_agg_fn.cpp | 34 +-
be/src/exprs/vectorized_agg_fn.h | 58 +-
be/src/exprs/vectorized_fn_call.cpp | 20 +
be/src/exprs/vectorized_fn_call.h | 4 +
be/src/exprs/vexpr.cpp | 8 +
be/src/exprs/vexpr.h | 5 +
be/src/exprs/vexpr_context.cpp | 32 +
be/src/exprs/vexpr_context.h | 5 +
be/src/exprs/vin_predicate.cpp | 19 +
be/src/exprs/vin_predicate.h | 4 +
be/src/format/orc/vorc_reader.cpp | 13 +-
be/src/format_v2/column_mapper.cpp | 51 +-
be/src/format_v2/column_mapper.h | 22 +-
.../delimited_text/delimited_text_reader.cpp | 4 +-
be/src/format_v2/file_reader.cpp | 13 +-
be/src/format_v2/file_reader.h | 22 +-
be/src/format_v2/jni/jni_table_reader.cpp | 1 +
be/src/format_v2/json/json_reader.cpp | 2 +-
be/src/format_v2/native/native_reader.cpp | 2 +-
be/src/format_v2/parquet/parquet_file_context.cpp | 16 +
be/src/format_v2/parquet/parquet_profile.cpp | 13 +
be/src/format_v2/parquet/parquet_profile.h | 4 +
be/src/format_v2/parquet/parquet_reader.cpp | 66 +-
be/src/format_v2/parquet/parquet_reader.h | 2 +
be/src/format_v2/parquet/parquet_scan.cpp | 103 +-
be/src/format_v2/parquet/parquet_scan.h | 6 +-
be/src/format_v2/parquet/parquet_statistics.cpp | 636 ++++++---
be/src/format_v2/parquet/parquet_statistics.h | 27 +-
be/src/format_v2/table/hudi_reader.cpp | 1 -
be/src/format_v2/table/paimon_reader.cpp | 1 -
be/src/format_v2/table/remote_doris_reader.cpp | 2 +-
be/src/format_v2/table_reader.cpp | 41 +-
be/src/format_v2/table_reader.h | 35 +-
be/src/information_schema/schema_scanner.h | 2 +
.../information_schema/schema_tables_scanner.cpp | 1 +
be/src/io/cache/block_file_cache.cpp | 91 ++
be/src/io/cache/block_file_cache.h | 8 +
be/src/io/cache/cached_remote_file_reader.cpp | 93 ++
be/src/io/cache/cached_remote_file_reader.h | 17 +
be/src/io/io_common.h | 6 +
.../load/channel/adaptive_random_bucket_state.cpp | 106 ++
be/src/load/channel/adaptive_random_bucket_state.h | 54 +
be/src/load/channel/load_channel_mgr.cpp | 2 +-
be/src/load/channel/tablets_channel.cpp | 226 ++-
be/src/load/channel/tablets_channel.h | 17 +
be/src/load/delta_writer/delta_writer.cpp | 33 +-
be/src/load/delta_writer/delta_writer.h | 12 +-
be/src/load/delta_writer/delta_writer_context.h | 1 +
be/src/load/delta_writer/delta_writer_v2.cpp | 23 +-
be/src/load/delta_writer/delta_writer_v2.h | 3 +-
be/src/load/memtable/memtable.cpp | 4 +
be/src/load/memtable/memtable_memory_limiter.cpp | 71 +-
be/src/load/memtable/memtable_memory_limiter.h | 4 +-
be/src/load/memtable/memtable_writer.cpp | 38 +-
be/src/load/memtable/memtable_writer.h | 6 +-
be/src/service/doris_main.cpp | 20 +-
.../service/http/action/be_thread_stack_action.cpp | 364 ++---
.../bloom_filter/bloom_filter_index_reader.cpp | 18 +-
.../index/bloom_filter/bloom_filter_index_reader.h | 19 +-
be/src/storage/index/indexed_column_reader.cpp | 23 +-
be/src/storage/index/indexed_column_reader.h | 18 +-
be/src/storage/index/ordinal_page_index.cpp | 15 +-
be/src/storage/index/ordinal_page_index.h | 10 +-
be/src/storage/index/zone_map/zone_map_index.cpp | 14 +-
be/src/storage/index/zone_map/zone_map_index.h | 6 +-
.../storage/iterator/binlog_block_reader_utils.h | 8 +-
be/src/storage/iterator/block_reader.cpp | 4 +
be/src/storage/iterator/vertical_block_reader.cpp | 4 +
be/src/storage/rowset/beta_rowset_reader.cpp | 6 +-
be/src/storage/rowset/rowset_meta.h | 14 +-
be/src/storage/rowset/rowset_reader_context.h | 3 +
be/src/storage/schema.cpp | 1 +
be/src/storage/schema.h | 5 +
be/src/storage/schema_change/schema_change.cpp | 4 +
be/src/storage/segment/column_reader.cpp | 34 +-
be/src/storage/segment/column_reader.h | 107 +-
be/src/storage/segment/column_reader_cache.cpp | 4 +-
be/src/storage/segment/column_reader_cache.h | 6 +-
be/src/storage/segment/segment.cpp | 47 +-
be/src/storage/segment/segment.h | 7 +-
be/src/storage/tablet/base_tablet.cpp | 18 +-
be/src/storage/tablet/base_tablet.h | 2 +-
be/src/storage/tablet/tablet_meta.cpp | 3 +
be/src/storage/tablet/tablet_reader.cpp | 1 +
be/src/storage/tablet/tablet_reader.h | 3 +
be/src/storage/tablet/tablet_schema.cpp | 7 +
be/src/storage/tablet/tablet_schema.h | 2 +
be/src/storage/tablet_info.cpp | 25 +-
be/src/storage/tablet_info.h | 8 +
be/src/storage/utils.h | 1 +
be/src/util/dynamic_util.cpp | 17 +
be/src/util/libjvm_loader.cpp | 30 +-
be/src/util/stack_util.cpp | 55 -
be/src/util/stack_util.h | 34 +-
be/test/CMakeLists.txt | 13 +
be/test/cloud/cloud_meta_mgr_test.cpp | 62 +
be/test/common/phdr_cache_test.cpp | 103 ++
.../test/common/phdr_cache_test_dso.cpp | 13 +-
be/test/core/column/column_string_test.cpp | 20 +
be/test/exec/agg/agg_fn_evaluator_test.cpp | 581 +++++++-
be/test/exec/operator/agg_operator_test.cpp | 2 +-
.../operator/materialization_shared_state_test.cpp | 86 +-
be/test/exec/scan/file_scanner_v2_test.cpp | 117 ++
be/test/exec/sink/vrow_distribution_test.cpp | 44 +-
be/test/exprs/aggregate/agg_function_test.h | 75 +-
be/test/exprs/aggregate/agg_test.cpp | 114 ++
be/test/exprs/expr_zonemap_filter_test.cpp | 120 ++
be/test/format/orc/orc_reader_fill_data_test.cpp | 36 +
be/test/format_v2/column_mapper_test.cpp | 280 ++--
.../format_v2/delimited_text/csv_reader_test.cpp | 3 +
be/test/format_v2/parquet/parquet_reader_test.cpp | 146 +-
be/test/format_v2/parquet/parquet_scan_test.cpp | 228 ++-
.../format_v2/parquet/parquet_statistics_test.cpp | 534 ++++---
be/test/format_v2/table/hive_reader_test.cpp | 1 -
be/test/format_v2/table/iceberg_reader_test.cpp | 41 +-
be/test/format_v2/table/paimon_reader_test.cpp | 2 -
be/test/format_v2/table_reader_test.cpp | 256 ++--
be/test/io/cache/block_file_cache_test.cpp | 134 ++
.../channel/adaptive_random_bucket_state_test.cpp | 94 ++
.../service/http/be_thread_stack_action_test.cpp | 50 +-
.../iterator/block_reader_min_delta_test.cpp | 15 +-
.../segment/constant_column_iterator_test.cpp | 192 +++
.../segment/segment_iterator_expr_zonemap_test.cpp | 131 +-
be/test/storage/tablet/tablet_schema_helper.cpp | 14 +
be/test/storage/tablet/tablet_schema_helper.h | 2 +
be/test/storage/tablet/tablet_schema_test.cpp | 34 +
be/test/testutil/run_all_tests.cpp | 1 +
build-for-release.sh | 8 +-
build.sh | 38 +-
cloud/CMakeLists.txt | 7 +
cloud/cmake/thirdparty.cmake | 3 +
docker/runtime/README.md | 3 -
docker/runtime/all-in-one/Dockerfile | 3 +-
docker/runtime/all-in-one/resource/entry_point.sh | 62 +-
docker/runtime/broker/Dockerfile | 54 -
.../broker/resource/amd64/x64_package_is_here | 23 -
.../broker/resource/arm64/arm64_package_is_here | 23 -
.../runtime/broker/resource/broker_entrypoint.sh | 210 ---
docker/runtime/broker/resource/broker_is_alive.sh | 39 -
docker/runtime/broker/resource/broker_prestop.sh | 21 -
docker/runtime/broker/resource/init_broker.sh | 192 ---
docker/runtime/docker-build.sh | 5 -
.../example/hdfs-broker-doris/broker-init.sql | 29 -
.../example/hdfs-broker-doris/docker-compose.yaml | 97 --
.../example/hdfs-broker-doris/doris-init.sql | 27 -
.../example/hdfs-broker-doris/hdfs-init.sql | 18 -
.../example/hdfs-broker-doris/user_basic_data.sql | 20 -
docker/runtime/doris-compose/cluster.py | 25 +-
docker/runtime/doris-compose/command.py | 25 +
docker/runtime/doris-compose/resource/init_fe.sh | 4 +
.../main/java/org/apache/doris/catalog/Column.java | 11 +-
.../main/java/org/apache/doris/common/Config.java | 11 +
.../ConfigurationAWSCredentialsProvider.java | 45 +-
.../apache/doris/alter/SchemaChangeHandler.java | 3 +
.../org/apache/doris/analysis/TableScanParams.java | 31 +-
.../java/org/apache/doris/binlog/BinlogUtils.java | 6 +
.../java/org/apache/doris/catalog/LocalTablet.java | 32 +-
.../java/org/apache/doris/catalog/OlapTable.java | 48 +-
.../org/apache/doris/catalog/OlapTableWrapper.java | 38 +-
.../doris/catalog/RowBinlogTableWrapper.java | 37 +-
.../java/org/apache/doris/catalog/TableIf.java | 34 +
.../doris/catalog/stream/OlapTableStream.java | 41 +-
.../catalog/stream/OlapTableStreamUpdate.java | 27 +-
.../catalog/stream/OlapTableStreamWrapper.java | 65 +-
.../cloud/alter/CloudSchemaChangeHandler.java | 9 +-
.../cloud/datasource/CloudInternalCatalog.java | 5 +
.../doris/cloud/load/CloudRoutineLoadManager.java | 3 +-
.../doris/common/proc/FrontendsProcNode.java | 3 +-
.../doris/common/profile/SummaryProfile.java | 25 +
.../org/apache/doris/common/util/HttpURLUtil.java | 5 +
.../apache/doris/common/util/PropertyAnalyzer.java | 32 +-
.../apache/doris/datasource/InternalCatalog.java | 1 +
.../apache/doris/datasource/kafka/KafkaUtil.java | 12 +-
.../doris/datasource/kinesis/KinesisUtil.java | 20 +-
.../apache/doris/job/util/StreamingJobUtils.java | 1 +
.../org/apache/doris/load/GroupCommitManager.java | 10 +-
.../org/apache/doris/load/StreamLoadHandler.java | 3 +-
.../doris/load/routineload/RoutineLoadManager.java | 16 +-
.../org/apache/doris/nereids/NereidsPlanner.java | 30 +-
.../glue/translator/PhysicalPlanTranslator.java | 37 +-
.../doris/nereids/rules/analysis/BindRelation.java | 250 +++-
.../nereids/rules/analysis/NormalizeAggregate.java | 2 +-
.../LogicalOlapScanToPhysicalOlapScan.java | 1 -
.../rewrite/NormalizeOlapTableStreamScan.java | 411 ++++--
.../nereids/rules/rewrite/PruneOlapScanTablet.java | 2 +-
.../rules/rewrite/PushDownJoinOtherCondition.java | 1 -
.../nereids/rules/rewrite/SetPreAggStatus.java | 5 -
.../rewrite/eageraggregation/EagerAggRewriter.java | 54 +-
.../eageraggregation/PushDownAggContext.java | 27 +-
.../eageraggregation/PushDownAggregation.java | 34 +-
.../doris/nereids/trees/expressions/CaseWhen.java | 2 +-
.../doris/nereids/trees/expressions/IsFalse.java | 3 +-
.../doris/nereids/trees/expressions/IsNull.java | 2 +-
.../doris/nereids/trees/expressions/IsTrue.java | 3 +-
.../nereids/trees/expressions/NullSafeEqual.java | 2 +-
.../trees/expressions/NullToNonNullFunction.java | 57 +
.../expressions/functions/scalar/Coalesce.java | 3 +-
.../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 +-
.../functions/scalar/ToIpv4OrDefault.java | 3 +-
.../functions/scalar/ToIpv6OrDefault.java | 3 +-
.../trees/plans/commands/ShowDataCommand.java | 4 +-
.../plans/commands/info/ColumnDefinition.java | 12 +
.../trees/plans/commands/info/CreateTableInfo.java | 15 +
.../commands/info/ModifyTablePropertiesOp.java | 2 +
.../commands/insert/InsertIntoTableCommand.java | 47 +-
.../insert/StreamConsumptionInfoExtractor.java | 93 ++
.../trees/plans/logical/LogicalOlapScan.java | 49 +-
.../plans/logical/LogicalOlapTableStreamScan.java | 176 ++-
.../nereids/trees/plans/logical/LogicalUnion.java | 2 +-
.../trees/plans/physical/PhysicalOlapScan.java | 24 +-
.../org/apache/doris/planner/OlapScanNode.java | 55 +-
.../org/apache/doris/planner/OlapTableSink.java | 415 ++++++
.../main/java/org/apache/doris/qe/Coordinator.java | 198 ++-
.../org/apache/doris/qe/NereidsCoordinator.java | 2 -
.../java/org/apache/doris/qe/SessionVariable.java | 20 +-
.../doris/qe/TimeBasedChangeVisibleWaiter.java | 178 +++
.../doris/qe/runtime/ThriftPlansBuilder.java | 61 +
.../apache/doris/service/FrontendServiceImpl.java | 214 ++-
.../org/apache/doris/system/BeSelectionPolicy.java | 12 +-
.../CdcStreamTableValuedFunction.java | 12 +-
.../org/apache/doris/task/CreateReplicaTask.java | 5 +
.../org/apache/doris/alter/RollupJobV2Test.java | 58 +
.../apache/doris/analysis/TableScanParamsTest.java | 95 ++
.../org/apache/doris/catalog/OlapTableTest.java | 36 +
.../java/org/apache/doris/catalog/TabletTest.java | 17 +
.../catalog/stream/OlapTableStreamUpdateTest.java | 22 +-
.../stream/TableStreamManagerCleanupTest.java | 7 -
.../apache/doris/common/PropertyAnalyzerTest.java | 38 +
.../apache/doris/load/StreamLoadHandlerTest.java | 69 +
.../RoutineLoadBackendSelectionTest.java | 169 +++
.../load/routineload/RoutineLoadManagerTest.java | 11 +
.../eageraggregation/EagerAggRewriterTest.java | 239 +++-
.../trees/plans/ExplainTableStreamPlanTest.java | 123 +-
.../trees/plans/commands/ShowDataCommandTest.java | 53 +
.../InsertIntoTableCommandTableStreamTest.java | 74 +-
.../apache/doris/planner/OlapTableSinkTest.java | 134 ++
.../doris/qe/TimeBasedChangeVisibleWaiterTest.java | 140 ++
.../apache/doris/qe/WaitForChangeVisibleTest.java | 204 ---
.../doris/service/FrontendServiceImplTest.java | 176 +++
.../apache/doris/system/SystemInfoServiceTest.java | 10 +-
.../CdcStreamTableValuedFunctionTest.java | 101 ++
.../TableStreamOffsetTransactionTest.java | 20 +-
fs_brokers/apache_hdfs_broker/.gitignore | 1 -
fs_brokers/apache_hdfs_broker/bin/start_broker.sh | 121 --
fs_brokers/apache_hdfs_broker/bin/stop_broker.sh | 49 -
fs_brokers/apache_hdfs_broker/build.sh | 51 -
.../conf/apache_hdfs_broker.conf | 29 -
fs_brokers/apache_hdfs_broker/conf/hdfs-site.xml | 23 -
.../apache_hdfs_broker/conf/log4j.properties | 30 -
fs_brokers/apache_hdfs_broker/pom.xml | 571 --------
.../apache/doris/broker/hdfs/BrokerBootstrap.java | 86 --
.../org/apache/doris/broker/hdfs/BrokerConfig.java | 39 -
.../apache/doris/broker/hdfs/BrokerException.java | 69 -
.../apache/doris/broker/hdfs/BrokerFileSystem.java | 120 --
.../doris/broker/hdfs/ClientContextManager.java | 272 ----
.../doris/broker/hdfs/FileSystemIdentity.java | 85 --
.../doris/broker/hdfs/FileSystemManager.java | 1491 --------------------
.../doris/broker/hdfs/HDFSBrokerServiceImpl.java | 334 -----
.../java/org/apache/doris/common/ConfigBase.java | 197 ---
.../java/org/apache/doris/common/HiveUtils.java | 112 --
.../apache/doris/common/LoggerMessageFormat.java | 271 ----
.../java/org/apache/doris/common/ThriftServer.java | 116 --
.../java/org/apache/doris/common/WildcardURI.java | 77 -
.../doris/broker/hdfs/TestFileSystemManager.java | 214 ---
.../doris/broker/hdfs/TestHDFSBrokerService.java | 66 -
.../apache/doris/broker/hdfs/WildcardURITest.java | 54 -
gensrc/proto/internal_service.proto | 22 +
gensrc/proto/olap_file.proto | 6 +
gensrc/thrift/AgentService.thrift | 1 +
gensrc/thrift/DataSinks.thrift | 9 +
gensrc/thrift/Descriptors.thrift | 13 +-
gensrc/thrift/FrontendService.thrift | 13 +-
gensrc/thrift/PaloInternalService.thrift | 1 +
.../outfile/csv/test_outfile_empty_data.out | 2 -
.../hive/test_hive_broker_scan.out | 18 -
.../tvf/test_hdfs_parquet_group4.out | 115 +-
.../test_max_compute_in_predicate_pushdown.out | 24 +
.../test_multi_match_null_query.out | 28 +
..._streaming_job_cdc_stream_mysql_delete_sign.out | 21 +
...reaming_job_cdc_stream_postgres_delete_sign.out | 21 +
.../data/load_p0/stream_load/test_json_load.out | 23 -
.../window_functions/test_column_boundary.out | 3 +-
.../data/query_p0/subquery/subquery_unnesting.out | 3 +
.../test_olap_table_stream_history_consumption.out | 9 -
.../test_olap_table_stream_history_query.out | 197 ---
...olap_table_stream_mixed_history_incremental.out | 8 +
.../test_table_stream_query_comprehensive.out | 38 +
.../test_time_travel_dup.out} | 21 +-
.../test_time_travel_mow.out} | 16 +-
.../test_time_travel_mow_complex.out} | 18 +-
.../org/apache/doris/regression/Config.groovy | 32 +-
.../apache/doris/regression/ConfigOptions.groovy | 32 +-
.../doris/regression/action/ProfileAction.groovy | 107 +-
.../doris/regression/suite/SuiteCluster.groovy | 51 +-
.../pipeline/external/conf/regression-conf.groovy | 1 -
.../pipeline/p0/conf/regression-conf.groovy | 1 -
regression-test/plugins/plugin_compaction.groovy | 7 +-
...e_warm_up_with_compaction_use_peer_cache.groovy | 2 +-
.../suites/cloud_p0/cache/ddl/nation.sql | 3 +
.../read_write/test_multi_stale_rowset.groovy | 2 +-
...topn_lazy_mat_phase2_no_write_file_cache.groovy | 294 ++++
.../cloud_p0/cache/ttl/alter_ttl_max_int64.groovy | 41 +-
.../test_fe_cached_partition_version.groovy | 34 +-
.../compaction/test_compacation_with_delete.groovy | 2 +-
.../compaction/test_compaction_agg_keys.groovy | 2 +-
.../test_compaction_agg_keys_with_array_map.groovy | 3 +-
.../test_compaction_agg_keys_with_delete.groovy | 2 +-
.../compaction/test_compaction_dup_keys.groovy | 2 +-
.../test_compaction_dup_keys_with_delete.groovy | 2 +-
.../compaction/test_compaction_uniq_keys.groovy | 2 +-
.../compaction/test_compaction_uniq_keys_ck.groovy | 3 +-
.../test_compaction_uniq_keys_row_store.groovy | 1 +
.../test_compaction_uniq_keys_row_store_ck.groovy | 1 +
.../test_compaction_uniq_keys_with_delete.groovy | 2 +-
...test_compaction_uniq_keys_with_delete_ck.groovy | 3 +-
.../test_compaction_with_empty_rowset.groovy | 3 +-
.../test_vertical_compaction_agg_keys.groovy | 2 +-
.../test_vertical_compaction_agg_state.groovy | 2 +-
.../test_vertical_compaction_dup_keys.groovy | 2 +-
.../test_vertical_compaction_uniq_keys.groovy | 2 +-
.../test_vertical_compaction_uniq_keys_ck.groovy | 2 +-
.../outfile/csv/test_outfile_empty_data.groovy | 32 -
.../outfile/native/test_outfile_native.groovy | 17 +-
.../suites/export_p0/test_outfile.groovy | 14 +-
.../suites/export_p0/test_outfile_expr.groovy | 14 +-
.../broker_load/test_broker_load_func.groovy | 85 --
.../hive/test_different_column_orders.groovy | 1 +
.../hive/test_hive_broker_scan.groovy | 61 -
.../hive/test_hive_orc_timestamp_timezone.groovy | 132 ++
.../external_table_p0/tvf/test_http_tvf.groovy | 166 ++-
.../hive/test_parquet_complex_cross_page.groovy | 55 -
.../test_max_compute_in_predicate_pushdown.groovy | 102 ++
.../hive_on_hms_and_dlf.groovy | 65 +-
.../test_disable_move_memtable.groovy | 95 --
.../test_tables_status_column_pruning.groovy | 97 ++
.../index_change/test_index_change_6.groovy | 19 +-
.../test_multi_match_null_query.groovy | 76 +
...reaming_job_cdc_stream_mysql_delete_sign.groovy | 157 +++
...ming_job_cdc_stream_postgres_delete_sign.groovy | 159 +++
.../broker_load/test_broker_load_with_merge.groovy | 237 ----
.../test_broker_load_without_seq.groovy | 101 --
.../insert/test_adaptive_random_bucket_load.groovy | 76 +
.../test_insert_random_distribution_table.groovy | 11 +-
.../test_routine_load_error_info.groovy | 18 +-
.../load_p0/stream_load/test_json_load.groovy | 105 --
.../suites/point_query_p0/test_point_query.groovy | 2 +-
.../query_p0/subquery/subquery_unnesting.groovy | 5 +
...ptive_pipeline_task_serial_read_on_limit.groovy | 55 +-
.../query_profile/s3_load_profile_test.groovy | 140 +-
.../suites/query_profile/scanner_profile.groovy | 137 +-
.../test_agg_keys_schema_change_datev2.groovy | 2 +-
.../test_schema_change_varchar_to_datev2.groovy | 2 +-
.../test_agg_keys_schema_change_decimalv2.groovy | 2 +-
.../test_agg_keys_schema_change_decimalv3.groovy | 2 +-
.../test_agg_keys_schema_change.groovy | 2 +-
.../test_agg_mv_schema_change.groovy | 3 +-
.../test_agg_rollup_schema_change.groovy | 2 +-
.../test_agg_vals_schema_change.groovy | 2 +-
.../test_dup_mv_schema_change.groovy | 2 +-
.../test_dup_rollup_schema_change.groovy | 2 +-
.../test_dup_vals_schema_change.groovy | 2 +-
.../test_schema_change_with_empty_rowset.groovy | 4 +-
.../test_uniq_mv_schema_change.groovy | 2 +-
.../test_uniq_rollup_schema_change.groovy | 2 +-
.../test_uniq_vals_schema_change.groovy | 2 +-
.../test_varchar_schema_change.groovy | 2 +-
.../suites/show_p0/test_show_data_all_db.groovy | 41 +
.../table_stream_p0/test_min_delta_stream.groovy | 17 +-
...st_olap_table_stream_history_consumption.groovy | 4 -
.../test_olap_table_stream_history_query.groovy | 117 +-
...p_table_stream_mixed_history_incremental.groovy | 71 +
.../test_olap_table_stream_reset.groovy | 293 ++++
.../test_olap_table_stream_snapshot.groovy | 276 ++++
.../test_olap_table_stream_snapshot_count.groovy | 88 ++
.../test_table_stream_query_comprehensive.groovy | 735 ++++++++++
.../time_travel_p0/test_time_travel_dup.groovy | 83 ++
.../time_travel_p0/test_time_travel_mow.groovy | 90 ++
.../test_time_travel_mow_complex.groovy | 70 +
.../predefine/test_custom_analyzer.groovy | 5 +-
run-be-ut.sh | 9 -
sdk/go-doris-sdk/README.md | 401 ------
sdk/go-doris-sdk/cmd/compress_bench/main.go | 85 --
sdk/go-doris-sdk/cmd/demo/main.go | 109 --
sdk/go-doris-sdk/cmd/examples/main.go | 122 --
sdk/go-doris-sdk/doris.go | 95 --
.../examples/concurrent_load_example.go | 123 --
sdk/go-doris-sdk/examples/data_generator.go | 222 ---
sdk/go-doris-sdk/examples/format_usage_example.go | 127 --
sdk/go-doris-sdk/examples/gzip_example.go | 64 -
sdk/go-doris-sdk/examples/label_removal_demo.go | 149 --
.../examples/production_concurrent_example.go | 214 ---
.../examples/production_json_example.go | 104 --
.../examples/production_single_batch_example.go | 101 --
sdk/go-doris-sdk/examples/simple_config_example.go | 69 -
sdk/go-doris-sdk/go.mod | 30 -
sdk/go-doris-sdk/go.sum | 17 -
.../pkg/load/client/doris_load_client.go | 347 -----
sdk/go-doris-sdk/pkg/load/config/load_config.go | 159 ---
.../pkg/load/exception/stream_load_error.go | 36 -
sdk/go-doris-sdk/pkg/load/load.go | 222 ---
.../pkg/load/loader/request_builder.go | 211 ---
sdk/go-doris-sdk/pkg/load/loader/resp_content.go | 79 --
sdk/go-doris-sdk/pkg/load/loader/stream_loader.go | 125 --
sdk/go-doris-sdk/pkg/load/logger/log.go | 257 ----
sdk/go-doris-sdk/pkg/load/util/http_client.go | 58 -
sdk/go-doris-sdk/pkg/load/util/http_client_test.go | 199 ---
sdk/java-doris-sdk/README.md | 310 ----
sdk/java-doris-sdk/pom.xml | 85 --
.../java/org/apache/doris/sdk/DorisClient.java | 82 --
.../doris/sdk/examples/ConcurrentExample.java | 190 ---
.../apache/doris/sdk/examples/DataGenerator.java | 148 --
.../apache/doris/sdk/examples/ExamplesMain.java | 75 -
.../org/apache/doris/sdk/examples/GzipExample.java | 79 --
.../org/apache/doris/sdk/examples/JsonExample.java | 97 --
.../doris/sdk/examples/SimpleConfigExample.java | 81 --
.../doris/sdk/examples/SingleBatchExample.java | 91 --
.../org/apache/doris/sdk/load/DorisLoadClient.java | 227 ---
.../apache/doris/sdk/load/config/CsvFormat.java | 52 -
.../apache/doris/sdk/load/config/DorisConfig.java | 146 --
.../org/apache/doris/sdk/load/config/Format.java | 32 -
.../doris/sdk/load/config/GroupCommitMode.java | 31 -
.../apache/doris/sdk/load/config/JsonFormat.java | 63 -
.../apache/doris/sdk/load/config/RetryConfig.java | 66 -
.../sdk/load/exception/StreamLoadException.java | 33 -
.../doris/sdk/load/internal/RequestBuilder.java | 166 ---
.../doris/sdk/load/internal/StreamLoader.java | 149 --
.../apache/doris/sdk/load/model/LoadResponse.java | 56 -
.../apache/doris/sdk/load/model/RespContent.java | 92 --
.../src/main/resources/log4j.properties | 23 -
.../apache/doris/sdk/load/DorisLoadClientTest.java | 129 --
.../doris/sdk/load/config/DorisConfigTest.java | 112 --
.../apache/doris/sdk/load/config/FormatTest.java | 64 -
.../sdk/load/internal/RequestBuilderTest.java | 113 --
.../doris/sdk/load/model/LoadResponseTest.java | 78 -
thirdparty/build-thirdparty.sh | 38 +-
thirdparty/download-thirdparty.sh | 14 +
.../patches/libunwind-1.6.2-doris-phdr-cache.patch | 31 +
threat-model.md | 6 +-
tools/fast-fe-ut.sh | 266 ++++
556 files changed, 16357 insertions(+), 17039 deletions(-)
create mode 100644 be/src/load/channel/adaptive_random_bucket_state.cpp
create mode 100644 be/src/load/channel/adaptive_random_bucket_state.h
create mode 100644 be/test/common/phdr_cache_test.cpp
rename
fs_brokers/apache_hdfs_broker/src/main/java/org/apache/doris/common/BrokerPerfMonitor.java
=> be/test/common/phdr_cache_test_dso.cpp (74%)
create mode 100644 be/test/load/channel/adaptive_random_bucket_state_test.cpp
create mode 100644 be/test/storage/segment/constant_column_iterator_test.cpp
delete mode 100644 docker/runtime/broker/Dockerfile
delete mode 100644 docker/runtime/broker/resource/amd64/x64_package_is_here
delete mode 100644 docker/runtime/broker/resource/arm64/arm64_package_is_here
delete mode 100755 docker/runtime/broker/resource/broker_entrypoint.sh
delete mode 100755 docker/runtime/broker/resource/broker_is_alive.sh
delete mode 100755 docker/runtime/broker/resource/broker_prestop.sh
delete mode 100644 docker/runtime/broker/resource/init_broker.sh
delete mode 100644
docker/runtime/docker-compose-demo/example/hdfs-broker-doris/broker-init.sql
delete mode 100644
docker/runtime/docker-compose-demo/example/hdfs-broker-doris/docker-compose.yaml
delete mode 100644
docker/runtime/docker-compose-demo/example/hdfs-broker-doris/doris-init.sql
delete mode 100644
docker/runtime/docker-compose-demo/example/hdfs-broker-doris/hdfs-init.sql
delete mode 100644
docker/runtime/docker-compose-demo/example/hdfs-broker-doris/user_basic_data.sql
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/NullToNonNullFunction.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/insert/StreamConsumptionInfoExtractor.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/qe/TimeBasedChangeVisibleWaiter.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/analysis/TableScanParamsTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/load/StreamLoadHandlerTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/load/routineload/RoutineLoadBackendSelectionTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/planner/OlapTableSinkTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/qe/TimeBasedChangeVisibleWaiterTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/qe/WaitForChangeVisibleTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/tablefunction/CdcStreamTableValuedFunctionTest.java
delete mode 100644 fs_brokers/apache_hdfs_broker/.gitignore
delete mode 100755 fs_brokers/apache_hdfs_broker/bin/start_broker.sh
delete mode 100755 fs_brokers/apache_hdfs_broker/bin/stop_broker.sh
delete mode 100755 fs_brokers/apache_hdfs_broker/build.sh
delete mode 100644 fs_brokers/apache_hdfs_broker/conf/apache_hdfs_broker.conf
delete mode 100644 fs_brokers/apache_hdfs_broker/conf/hdfs-site.xml
delete mode 100644 fs_brokers/apache_hdfs_broker/conf/log4j.properties
delete mode 100644 fs_brokers/apache_hdfs_broker/pom.xml
delete mode 100644
fs_brokers/apache_hdfs_broker/src/main/java/org/apache/doris/broker/hdfs/BrokerBootstrap.java
delete mode 100644
fs_brokers/apache_hdfs_broker/src/main/java/org/apache/doris/broker/hdfs/BrokerConfig.java
delete mode 100644
fs_brokers/apache_hdfs_broker/src/main/java/org/apache/doris/broker/hdfs/BrokerException.java
delete mode 100644
fs_brokers/apache_hdfs_broker/src/main/java/org/apache/doris/broker/hdfs/BrokerFileSystem.java
delete mode 100644
fs_brokers/apache_hdfs_broker/src/main/java/org/apache/doris/broker/hdfs/ClientContextManager.java
delete mode 100644
fs_brokers/apache_hdfs_broker/src/main/java/org/apache/doris/broker/hdfs/FileSystemIdentity.java
delete mode 100644
fs_brokers/apache_hdfs_broker/src/main/java/org/apache/doris/broker/hdfs/FileSystemManager.java
delete mode 100644
fs_brokers/apache_hdfs_broker/src/main/java/org/apache/doris/broker/hdfs/HDFSBrokerServiceImpl.java
delete mode 100644
fs_brokers/apache_hdfs_broker/src/main/java/org/apache/doris/common/ConfigBase.java
delete mode 100644
fs_brokers/apache_hdfs_broker/src/main/java/org/apache/doris/common/HiveUtils.java
delete mode 100644
fs_brokers/apache_hdfs_broker/src/main/java/org/apache/doris/common/LoggerMessageFormat.java
delete mode 100644
fs_brokers/apache_hdfs_broker/src/main/java/org/apache/doris/common/ThriftServer.java
delete mode 100644
fs_brokers/apache_hdfs_broker/src/main/java/org/apache/doris/common/WildcardURI.java
delete mode 100644
fs_brokers/apache_hdfs_broker/src/test/java/org/apache/doris/broker/hdfs/TestFileSystemManager.java
delete mode 100644
fs_brokers/apache_hdfs_broker/src/test/java/org/apache/doris/broker/hdfs/TestHDFSBrokerService.java
delete mode 100644
fs_brokers/apache_hdfs_broker/src/test/java/org/apache/doris/broker/hdfs/WildcardURITest.java
delete mode 100644
regression-test/data/external_table_p0/hive/test_hive_broker_scan.out
create mode 100644
regression-test/data/external_table_p2/maxcompute/test_max_compute_in_predicate_pushdown.out
create mode 100644
regression-test/data/inverted_index_p0/test_multi_match_null_query.out
create mode 100644
regression-test/data/job_p0/streaming_job/cdc/tvf/test_streaming_job_cdc_stream_mysql_delete_sign.out
create mode 100644
regression-test/data/job_p0/streaming_job/cdc/tvf/test_streaming_job_cdc_stream_postgres_delete_sign.out
delete mode 100644
regression-test/data/table_stream_p0/test_olap_table_stream_history_query.out
create mode 100644
regression-test/data/table_stream_p0/test_olap_table_stream_mixed_history_incremental.out
create mode 100644
regression-test/data/table_stream_p0/test_table_stream_query_comprehensive.out
copy regression-test/data/{export_p0/outfile/csv/test_outfile_empty_data.out
=> time_travel_p0/test_time_travel_dup.out} (50%)
copy
regression-test/data/{external_table_p2/hive/test_parquet_complex_cross_page.out
=> time_travel_p0/test_time_travel_mow.out} (61%)
rename
regression-test/data/{external_table_p2/hive/test_parquet_complex_cross_page.out
=> time_travel_p0/test_time_travel_mow_complex.out} (57%)
create mode 100644
regression-test/suites/cloud_p0/cache/topn_lazy_file_cache/test_topn_lazy_mat_phase2_no_write_file_cache.groovy
delete mode 100644
regression-test/suites/external_table_p0/broker_load/test_broker_load_func.groovy
delete mode 100644
regression-test/suites/external_table_p0/hive/test_hive_broker_scan.groovy
create mode 100644
regression-test/suites/external_table_p0/hive/test_hive_orc_timestamp_timezone.groovy
delete mode 100644
regression-test/suites/external_table_p2/hive/test_parquet_complex_cross_page.groovy
create mode 100644
regression-test/suites/external_table_p2/maxcompute/test_max_compute_in_predicate_pushdown.groovy
create mode 100644
regression-test/suites/information_schema_p0/test_tables_status_column_pruning.groovy
create mode 100644
regression-test/suites/inverted_index_p0/test_multi_match_null_query.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/tvf/test_streaming_job_cdc_stream_mysql_delete_sign.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/tvf/test_streaming_job_cdc_stream_postgres_delete_sign.groovy
delete mode 100644
regression-test/suites/load_p0/broker_load/test_broker_load_with_merge.groovy
delete mode 100644
regression-test/suites/load_p0/broker_load/test_broker_load_without_seq.groovy
create mode 100644
regression-test/suites/load_p0/insert/test_adaptive_random_bucket_load.groovy
create mode 100644 regression-test/suites/show_p0/test_show_data_all_db.groovy
create mode 100644
regression-test/suites/table_stream_p0/test_olap_table_stream_mixed_history_incremental.groovy
create mode 100644
regression-test/suites/table_stream_p0/test_olap_table_stream_reset.groovy
create mode 100644
regression-test/suites/table_stream_p0/test_olap_table_stream_snapshot.groovy
create mode 100644
regression-test/suites/table_stream_p0/test_olap_table_stream_snapshot_count.groovy
create mode 100644
regression-test/suites/table_stream_p0/test_table_stream_query_comprehensive.groovy
create mode 100644
regression-test/suites/time_travel_p0/test_time_travel_dup.groovy
create mode 100644
regression-test/suites/time_travel_p0/test_time_travel_mow.groovy
create mode 100644
regression-test/suites/time_travel_p0/test_time_travel_mow_complex.groovy
delete mode 100644 sdk/go-doris-sdk/README.md
delete mode 100644 sdk/go-doris-sdk/cmd/compress_bench/main.go
delete mode 100644 sdk/go-doris-sdk/cmd/demo/main.go
delete mode 100644 sdk/go-doris-sdk/cmd/examples/main.go
delete mode 100644 sdk/go-doris-sdk/doris.go
delete mode 100644 sdk/go-doris-sdk/examples/concurrent_load_example.go
delete mode 100644 sdk/go-doris-sdk/examples/data_generator.go
delete mode 100644 sdk/go-doris-sdk/examples/format_usage_example.go
delete mode 100644 sdk/go-doris-sdk/examples/gzip_example.go
delete mode 100644 sdk/go-doris-sdk/examples/label_removal_demo.go
delete mode 100644 sdk/go-doris-sdk/examples/production_concurrent_example.go
delete mode 100644 sdk/go-doris-sdk/examples/production_json_example.go
delete mode 100644 sdk/go-doris-sdk/examples/production_single_batch_example.go
delete mode 100644 sdk/go-doris-sdk/examples/simple_config_example.go
delete mode 100644 sdk/go-doris-sdk/go.mod
delete mode 100644 sdk/go-doris-sdk/go.sum
delete mode 100644 sdk/go-doris-sdk/pkg/load/client/doris_load_client.go
delete mode 100644 sdk/go-doris-sdk/pkg/load/config/load_config.go
delete mode 100644 sdk/go-doris-sdk/pkg/load/exception/stream_load_error.go
delete mode 100644 sdk/go-doris-sdk/pkg/load/load.go
delete mode 100644 sdk/go-doris-sdk/pkg/load/loader/request_builder.go
delete mode 100644 sdk/go-doris-sdk/pkg/load/loader/resp_content.go
delete mode 100644 sdk/go-doris-sdk/pkg/load/loader/stream_loader.go
delete mode 100644 sdk/go-doris-sdk/pkg/load/logger/log.go
delete mode 100644 sdk/go-doris-sdk/pkg/load/util/http_client.go
delete mode 100644 sdk/go-doris-sdk/pkg/load/util/http_client_test.go
delete mode 100644 sdk/java-doris-sdk/README.md
delete mode 100644 sdk/java-doris-sdk/pom.xml
delete mode 100644
sdk/java-doris-sdk/src/main/java/org/apache/doris/sdk/DorisClient.java
delete mode 100644
sdk/java-doris-sdk/src/main/java/org/apache/doris/sdk/examples/ConcurrentExample.java
delete mode 100644
sdk/java-doris-sdk/src/main/java/org/apache/doris/sdk/examples/DataGenerator.java
delete mode 100644
sdk/java-doris-sdk/src/main/java/org/apache/doris/sdk/examples/ExamplesMain.java
delete mode 100644
sdk/java-doris-sdk/src/main/java/org/apache/doris/sdk/examples/GzipExample.java
delete mode 100644
sdk/java-doris-sdk/src/main/java/org/apache/doris/sdk/examples/JsonExample.java
delete mode 100644
sdk/java-doris-sdk/src/main/java/org/apache/doris/sdk/examples/SimpleConfigExample.java
delete mode 100644
sdk/java-doris-sdk/src/main/java/org/apache/doris/sdk/examples/SingleBatchExample.java
delete mode 100644
sdk/java-doris-sdk/src/main/java/org/apache/doris/sdk/load/DorisLoadClient.java
delete mode 100644
sdk/java-doris-sdk/src/main/java/org/apache/doris/sdk/load/config/CsvFormat.java
delete mode 100644
sdk/java-doris-sdk/src/main/java/org/apache/doris/sdk/load/config/DorisConfig.java
delete mode 100644
sdk/java-doris-sdk/src/main/java/org/apache/doris/sdk/load/config/Format.java
delete mode 100644
sdk/java-doris-sdk/src/main/java/org/apache/doris/sdk/load/config/GroupCommitMode.java
delete mode 100644
sdk/java-doris-sdk/src/main/java/org/apache/doris/sdk/load/config/JsonFormat.java
delete mode 100644
sdk/java-doris-sdk/src/main/java/org/apache/doris/sdk/load/config/RetryConfig.java
delete mode 100644
sdk/java-doris-sdk/src/main/java/org/apache/doris/sdk/load/exception/StreamLoadException.java
delete mode 100644
sdk/java-doris-sdk/src/main/java/org/apache/doris/sdk/load/internal/RequestBuilder.java
delete mode 100644
sdk/java-doris-sdk/src/main/java/org/apache/doris/sdk/load/internal/StreamLoader.java
delete mode 100644
sdk/java-doris-sdk/src/main/java/org/apache/doris/sdk/load/model/LoadResponse.java
delete mode 100644
sdk/java-doris-sdk/src/main/java/org/apache/doris/sdk/load/model/RespContent.java
delete mode 100644 sdk/java-doris-sdk/src/main/resources/log4j.properties
delete mode 100644
sdk/java-doris-sdk/src/test/java/org/apache/doris/sdk/load/DorisLoadClientTest.java
delete mode 100644
sdk/java-doris-sdk/src/test/java/org/apache/doris/sdk/load/config/DorisConfigTest.java
delete mode 100644
sdk/java-doris-sdk/src/test/java/org/apache/doris/sdk/load/config/FormatTest.java
delete mode 100644
sdk/java-doris-sdk/src/test/java/org/apache/doris/sdk/load/internal/RequestBuilderTest.java
delete mode 100644
sdk/java-doris-sdk/src/test/java/org/apache/doris/sdk/load/model/LoadResponseTest.java
create mode 100644 thirdparty/patches/libunwind-1.6.2-doris-phdr-cache.patch
create mode 100755 tools/fast-fe-ut.sh
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
