This is an automated email from the ASF dual-hosted git repository.
kxiao pushed a change to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git
from 140e6d1f5b [Fix](PhysicalPlanTranslator) forget
setPushDownAggNoGrouping in OlapScanNode (#23675) (#23699)
new fd899995be [Feature](Routine Load)Support Partial Update (#22785)
new 2b13e37f49 [Opt](pipeline) Refactor the short circuit of join pipeline
(#23639)
new 37afc6df56 [fix](jdbc catalog) fix jdbc driver cache load error
(#23656)
new ba3f54dc2e [fix](deploy) fix deploy manager can't drop node (#23667)
new 5fc8602a1d [fix](planner)fix bug of resolve column (#23512)
new e55ba7ee85 [Bug](materialized-view) fix load db use analyzer to
analyze diffrent metaindex (#23673)
new 739bc0f945 [Fix](status) fix printing too many logs in
VNodeChannel::try_send_and_fetch_status #23693
new 7ced060550 [Fix](cache) fix query cache returns wrong result after
deleting partitions. (#23555)
new 90ea52147d [feature](nereids) support subquery in select list (#23271)
new 0972aff3ad [Fix](meta lock) Should not acquire wlock twice (#23666)
new 55bd284590 [fix](parquet) fix potential heap-use-after-free issue and
cache issue (#23638)
new c7ae52cd90 [fix](regression)fix case test_outfile_orc_max_file_size by
replace table_export_name #23648
The 12 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
be/src/agent/heartbeat_server.cpp | 53 ++-
be/src/common/status.h | 4 +-
be/src/http/action/tablet_migration_action.cpp | 6 +-
be/src/olap/tablet.cpp | 2 +-
be/src/olap/tablet_schema.h | 2 +-
be/src/runtime/cache/result_node.h | 11 +
be/src/runtime/types.cpp | 2 +-
be/src/runtime/user_function_cache.cpp | 25 +-
be/src/runtime/user_function_cache.h | 1 +
be/src/vec/exec/format/parquet/vparquet_reader.cpp | 18 +-
be/src/vec/exec/format/parquet/vparquet_reader.h | 19 +-
be/src/vec/exec/scan/new_olap_scanner.cpp | 7 +-
be/src/vec/sink/vtablet_sink.cpp | 2 +-
be/test/runtime/user_function_cache_test.cpp | 28 ++
.../ecosystem/udf/java-user-defined-function.md | 3 +-
.../Load/ALTER-ROUTINE-LOAD.md | 1 +
.../Load/CREATE-ROUTINE-LOAD.md | 3 +
.../ecosystem/udf/java-user-defined-function.md | 3 +-
.../Load/ALTER-ROUTINE-LOAD.md | 1 +
.../Load/CREATE-ROUTINE-LOAD.md | 3 +
.../apache/doris/common/jni/utils/UdfUtils.java | 96 ++----
.../java/org/apache/doris/udf/BaseExecutor.java | 57 +++-
.../java/org/apache/doris/udf/UdafExecutor.java | 15 +-
.../java/org/apache/doris/udf/UdfExecutor.java | 28 +-
.../doris/analysis/AlterRoutineLoadStmt.java | 29 ++
.../java/org/apache/doris/analysis/Analyzer.java | 29 +-
.../doris/analysis/CreateRoutineLoadStmt.java | 27 +-
.../java/org/apache/doris/catalog/Database.java | 5 +-
.../main/java/org/apache/doris/catalog/Env.java | 2 +-
.../java/org/apache/doris/catalog/OlapTable.java | 7 +-
.../main/java/org/apache/doris/catalog/Table.java | 3 +-
.../apache/doris/datasource/InternalCatalog.java | 6 +-
.../load/routineload/KafkaRoutineLoadJob.java | 4 +
.../doris/load/routineload/RoutineLoadJob.java | 15 +-
.../doris/nereids/jobs/executor/Analyzer.java | 11 +-
.../doris/nereids/jobs/executor/Rewriter.java | 9 +-
.../EliminateGroupByConstant.java | 3 +-
.../{rewrite => analysis}/NormalizeAggregate.java | 4 +-
.../nereids/rules/analysis/SubqueryToApply.java | 92 +++---
.../rules/implementation/AggregateStrategies.java | 2 +-
.../rules/rewrite/PushdownAliasThroughJoin.java | 5 +-
.../doris/nereids/trees/expressions/CaseWhen.java | 2 +-
.../trees/expressions/literal/DoubleLiteral.java | 5 +
.../trees/expressions/literal/FloatLiteral.java | 9 +
.../org/apache/doris/qe/cache/CacheAnalyzer.java | 14 +-
.../org/apache/doris/qe/cache/RowBatchBuilder.java | 3 +-
.../java/org/apache/doris/qe/cache/SqlCache.java | 9 +-
.../org/apache/doris/system/SystemInfoService.java | 2 +-
.../nereids/rules/analysis/AnalyzeCTETest.java | 2 +-
.../rules/analysis/AnalyzeWhereSubqueryTest.java | 70 ++--
.../rules/analysis/BindSlotReferenceTest.java | 7 +-
.../EliminateGroupByConstantTest.java | 3 +-
.../rules/analysis/FillUpMissingSlotsTest.java | 354 +++++++++++----------
.../NormalizeAggregateTest.java | 2 +-
.../rules/rewrite/AggregateStrategiesTest.java | 1 +
.../nereids/rules/rewrite/ColumnPruningTest.java | 17 +-
.../ExtractAndNormalizeWindowExpressionTest.java | 1 +
.../rewrite/PushdownAliasThroughJoinTest.java | 23 ++
.../PushdownExpressionsInHashConditionTest.java | 34 +-
.../rules/rewrite/mv/SelectRollupIndexTest.java | 4 +-
.../org/apache/doris/qe/PartitionCacheTest.java | 12 +-
gensrc/proto/internal_service.proto | 1 +
.../data/javaudf_p0/test_javaudf_with_decimal.out | 13 +
.../subquery/test_subquery_in_project.out | 50 +++
.../nereids_tpcds_shape_sf100_p0/shape/query1.out | 15 +-
.../nereids_tpcds_shape_sf100_p0/shape/query30.out | 15 +-
.../nereids_tpcds_shape_sf100_p0/shape/query51.out | 42 +--
.../nereids_tpcds_shape_sf100_p0/shape/query81.out | 15 +-
.../nereids_tpch_shape_sf1000_p0/shape/q20.out | 13 +-
.../data/nereids_tpch_shape_sf500_p0/shape/q20.out | 13 +-
.../java/org/apache/doris/udf/MyArrayDecimal.java | 19 +-
.../java/org/apache/doris/udf/MyMapDecimal.java | 19 +-
.../java/org/apache/doris/udf/MyMapRetDecimal.java | 42 +++
.../org/apache/doris/udf/MyReturnMapString.java | 1 -
.../org/apache/doris/udf/MySumReturnMapIntDou.java | 1 -
.../test_inlineview_error_msg.groovy | 80 +++++
.../test_outfile_orc_max_file_size.groovy | 2 +-
.../suites/javaudf_p0/test_javaudf_agg_map.groovy | 14 +-
.../javaudf_p0/test_javaudf_with_decimal.groovy | 97 ++++++
.../subquery/test_subquery_in_project.groovy | 120 +++++++
80 files changed, 1248 insertions(+), 541 deletions(-)
rename fe/fe-core/src/main/java/org/apache/doris/nereids/rules/{rewrite =>
analysis}/EliminateGroupByConstant.java (96%)
rename fe/fe-core/src/main/java/org/apache/doris/nereids/rules/{rewrite =>
analysis}/NormalizeAggregate.java (98%)
rename fe/fe-core/src/test/java/org/apache/doris/nereids/rules/{rewrite =>
analysis}/EliminateGroupByConstantTest.java (98%)
rename fe/fe-core/src/test/java/org/apache/doris/nereids/rules/{rewrite =>
analysis}/NormalizeAggregateTest.java (99%)
create mode 100644
regression-test/data/javaudf_p0/test_javaudf_with_decimal.out
create mode 100644
regression-test/data/nereids_p0/subquery/test_subquery_in_project.out
copy be/test/runtime/user_function_cache_test.cpp =>
regression-test/java-udf-src/src/main/java/org/apache/doris/udf/MyArrayDecimal.java
(62%)
copy be/test/runtime/user_function_cache_test.cpp =>
regression-test/java-udf-src/src/main/java/org/apache/doris/udf/MyMapDecimal.java
(59%)
create mode 100644
regression-test/java-udf-src/src/main/java/org/apache/doris/udf/MyMapRetDecimal.java
create mode 100644
regression-test/suites/correctness_p0/test_inlineview_error_msg.groovy
create mode 100644
regression-test/suites/javaudf_p0/test_javaudf_with_decimal.groovy
create mode 100644
regression-test/suites/nereids_p0/subquery/test_subquery_in_project.groovy
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
