database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[pipelineX](streaming agg) Fix wrong columns produced by streaming agg (#32411)

Browse Source 
* [pipelineX](streaming agg) Fix wrong columns produced by streaming agg

* update
This commit is contained in:
Gabriel
2024-03-18 21:07:11 +08:00
committed by yiguolei
parent 6c8b5bb26f
commit 590e1d52ec
3 changed files with 46 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
be/src/pipeline/pipeline_x/operator.cpp
View File

@ -449,7 +449,8 @@ Status StatefulOperatorX<LocalStateType>::get_block(RuntimeState* state, vectori
bool* eos) {
auto& local_state = get_local_state(state);
if (need_more_input_data(state)) {
local_state._child_block->clear_column_data();
local_state._child_block->clear_column_data(
OperatorX<LocalStateType>::_child_x->row_desc().num_materialized_slots());
RETURN_IF_ERROR(OperatorX<LocalStateType>::_child_x->get_block_after_projects(
state, local_state._child_block.get(), &local_state._child_eos));
*eos = local_state._child_eos;

3
regression-test/data/query_p0/join/test_join.out
View File

@ -3240,3 +3240,6 @@ false true true false false
-- !test --
-- !sql --
4

41
regression-test/suites/query_p0/join/test_join.groovy
View File

@ -1294,4 +1294,45 @@ suite("test_join", "query,p0") {
sql """INSERT INTO t0 (c0) VALUES (true);"""
sql """INSERT INTO t0 (c0) VALUES (false);"""
qt_test """SELECT t1.c0 FROM t1 RIGHT JOIN t0 ON true WHERE (abs(1)=0) GROUP BY t1.c0;"""
sql """ DROP TABLE IF EXISTS tbl2; """
sql """ DROP TABLE IF EXISTS tbl1; """
sql """ CREATE TABLE tbl1 (
data_dt DATE NULL COMMENT '数据日期',
engineer VARCHAR(100) NULL COMMENT '工程师'
) ENGINE=OLAP
UNIQUE KEY(data_dt, engineer)
PARTITION BY RANGE(data_dt)
(
FROM ('2022-11-05') TO ('2024-03-20') INTERVAL 1 DAY
)
DISTRIBUTED BY HASH(data_dt) BUCKETS 10
PROPERTIES (
"replication_allocation" = "tag.location.default: 1",
"group_commit_interval_ms" = "10000",
"group_commit_data_bytes" = "134217728"
); """
sql """ CREATE TABLE tbl2 (
data_dt DATE NULL COMMENT '数据日期'
) ENGINE=OLAP
UNIQUE KEY(data_dt)
PARTITION BY RANGE(data_dt)
(
FROM ('2022-11-05') TO ('2024-03-20') INTERVAL 1 DAY
)
DISTRIBUTED BY HASH(data_dt) BUCKETS 10
PROPERTIES (
"replication_allocation" = "tag.location.default: 1",
"min_load_replica_num" = "-1",
"is_being_synced" = "false",
"storage_format" = "V2",
"group_commit_interval_ms" = "10000",
"group_commit_data_bytes" = "134217728"
); """
sql """ insert into tbl1 values('2023-01-01', 'engineer1'),('2023-01-01', 'engineer2'),('2023-01-02', 'engineer3'),('2023-01-02', 'enginee4'); """
sql """ insert into tbl2 values('2023-01-01'); """
qt_sql """ select /*+SET_VAR(batch_size=1, enable_nereids_planner=false)*/ count(DISTINCT dcqewrt.engineer) as active_person_count from tbl1 dcqewrt left join [broadcast] tbl2 dd on dd.data_dt = dcqewrt.data_dt; """
sql """ DROP TABLE IF EXISTS tbl2; """
sql """ DROP TABLE IF EXISTS tbl1; """
}