This is an automated email from the ASF dual-hosted git repository.
zhangstar333 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
from e23bb788e7f [improvement](statistics)Make partition batch size
configurable and limit total rows to scan in partition analyze. (#36410)
add cb33587fa8a [chore](pipeline) remove non-pipelinex code from FE
(#36236)
No new revisions were added by this update.
Summary of changes:
be/src/runtime/fragment_mgr.cpp | 1 -
be/src/runtime/runtime_filter_mgr.h | 7 +-
.../main/java/org/apache/doris/common/Config.java | 3 -
.../cloud/planner/CloudStreamLoadPlanner.java | 10 -
.../org/apache/doris/common/profile/Profile.java | 6 +-
.../doris/common/profile/SummaryProfile.java | 9 +-
.../apache/doris/common/util/RuntimeProfile.java | 53 ++---
.../apache/doris/datasource/FileQueryScanNode.java | 1 -
.../doris/datasource/jdbc/source/JdbcScanNode.java | 3 +-
.../doris/datasource/odbc/source/OdbcScanNode.java | 3 +-
.../org/apache/doris/load/StreamLoadHandler.java | 20 +-
.../apache/doris/load/loadv2/BrokerLoadJob.java | 3 +-
.../apache/doris/load/loadv2/LoadLoadingTask.java | 1 -
.../doris/load/routineload/KafkaTaskInfo.java | 39 +---
.../doris/load/routineload/RoutineLoadJob.java | 44 ----
.../doris/load/sync/canal/CanalSyncChannel.java | 6 +-
.../post/RuntimeFilterPushDownVisitor.java | 1 -
.../nereids/processor/pre/PlanPreprocessors.java | 1 -
.../processor/pre/TurnOffPipelineForDml.java | 64 ------
.../doris/nereids/rules/rewrite/CTEInline.java | 3 +-
.../doris/nereids/rules/rewrite/OrExpansion.java | 4 +-
.../nereids/trees/plans/commands/LoadCommand.java | 3 +-
.../trees/plans/physical/PhysicalFileSink.java | 13 +-
.../apache/doris/planner/GroupCommitPlanner.java | 1 -
.../org/apache/doris/planner/OlapScanNode.java | 18 +-
.../org/apache/doris/planner/RuntimeFilter.java | 6 +-
.../java/org/apache/doris/planner/ScanNode.java | 17 +-
.../apache/doris/planner/StreamLoadPlanner.java | 242 +--------------------
.../main/java/org/apache/doris/qe/Coordinator.java | 46 +---
.../apache/doris/qe/InsertStreamTxnExecutor.java | 45 ++--
.../java/org/apache/doris/qe/SessionVariable.java | 56 +----
.../java/org/apache/doris/qe/StmtExecutor.java | 11 +-
.../apache/doris/service/FrontendServiceImpl.java | 20 +-
.../sessions/FlightSessionsManager.java | 2 -
.../doris/statistics/util/StatisticsUtil.java | 1 -
gensrc/thrift/PaloInternalService.thrift | 11 +-
.../load_p0/stream_load/test_pipeline_load.out | 7 -
.../load_p0/stream_load/test_pipeline_load.groovy | 171 ---------------
38 files changed, 92 insertions(+), 860 deletions(-)
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/processor/pre/TurnOffPipelineForDml.java
delete mode 100644
regression-test/data/load_p0/stream_load/test_pipeline_load.out
delete mode 100644
regression-test/suites/load_p0/stream_load/test_pipeline_load.groovy
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
