From d97cc353be88f5746aca043995ce950133467d22 Mon Sep 17 00:00:00 2001
From: xxhZs <1060434431@qq.com>
Date: Tue, 27 Aug 2024 13:58:49 +0800
Subject: [PATCH] fix comm

---
 src/frontend/src/scheduler/distributed/stage.rs | 6 +++---
 src/frontend/src/scheduler/local.rs             | 4 ++--
 2 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/src/frontend/src/scheduler/distributed/stage.rs b/src/frontend/src/scheduler/distributed/stage.rs
index debd59e43eab7..bb18e2143aa7f 100644
--- a/src/frontend/src/scheduler/distributed/stage.rs
+++ b/src/frontend/src/scheduler/distributed/stage.rs
@@ -1074,7 +1074,7 @@ impl StageRunner {
             }
             PlanNodeType::BatchIcebergScan => {
                 let node_body = execution_plan_node.node.clone();
-                let NodeBody::IcebergScan(mut iceberg_source_node) = node_body else {
+                let NodeBody::IcebergScan(mut iceberg_scan_node) = node_body else {
                     unreachable!();
                 };
 
@@ -1082,14 +1082,14 @@ impl StageRunner {
                     .expect("no partition info for seq scan")
                     .into_source()
                     .expect("PartitionInfo should be SourcePartitionInfo");
-                iceberg_source_node.split = partition
+                iceberg_scan_node.split = partition
                     .into_iter()
                     .map(|split| split.encode_to_bytes().into())
                     .collect_vec();
                 PbPlanNode {
                     children: vec![],
                     identity,
-                    node_body: Some(NodeBody::IcebergScan(iceberg_source_node)),
+                    node_body: Some(NodeBody::IcebergScan(iceberg_scan_node)),
                 }
             }
             _ => {
diff --git a/src/frontend/src/scheduler/local.rs b/src/frontend/src/scheduler/local.rs
index 5961a63c8e342..a727ddd9db7dd 100644
--- a/src/frontend/src/scheduler/local.rs
+++ b/src/frontend/src/scheduler/local.rs
@@ -580,12 +580,12 @@ impl LocalQueryExecution {
             PlanNodeType::BatchIcebergScan => {
                 let mut node_body = execution_plan_node.node.clone();
                 match &mut node_body {
-                    NodeBody::IcebergScan(ref mut iceberg_source_node) => {
+                    NodeBody::IcebergScan(ref mut iceberg_scan_node) => {
                         if let Some(partition) = partition {
                             let partition = partition
                                 .into_source()
                                 .expect("PartitionInfo should be SourcePartitionInfo here");
-                            iceberg_source_node.split = partition
+                            iceberg_scan_node.split = partition
                                 .into_iter()
                                 .map(|split| split.encode_to_bytes().into())
                                 .collect_vec();