fix comm

risingwavelabs · Aug 27, 2024 · d97cc35 · d97cc35
1 parent d82c8ea
commit d97cc35
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/src/frontend/src/scheduler/distributed/stage.rs b/src/frontend/src/scheduler/distributed/stage.rs
@@ -1074,22 +1074,22 @@ 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!();
                 };
 
                 let partition = partition
                     .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
@@ -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();