diff --git a/be/src/pipeline/pipeline_x/operator.cpp b/be/src/pipeline/pipeline_x/operator.cpp
index 5d966020f8..093bf17f46 100644
--- a/be/src/pipeline/pipeline_x/operator.cpp
+++ b/be/src/pipeline/pipeline_x/operator.cpp
@@ -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;
diff --git a/regression-test/data/query_p0/join/test_join.out b/regression-test/data/query_p0/join/test_join.out
index b360a86345..3814530e0c 100644
--- a/regression-test/data/query_p0/join/test_join.out
+++ b/regression-test/data/query_p0/join/test_join.out
@@ -3240,3 +3240,6 @@ false	true	true	false	false
 
 -- !test --
 
+-- !sql --
+4
+
diff --git a/regression-test/suites/query_p0/join/test_join.groovy b/regression-test/suites/query_p0/join/test_join.groovy
index 11d1e1bba8..5f25ea5223 100644
--- a/regression-test/suites/query_p0/join/test_join.groovy
+++ b/regression-test/suites/query_p0/join/test_join.groovy
@@ -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; """
 }