(texera) branch xinyuan-stage-by-stage updated: fix

[linxinyuan]

This is an automated email from the ASF dual-hosted git repository.

linxinyuan pushed a commit to branch xinyuan-stage-by-stage
in repository https://gitbox.apache.org/repos/asf/texera.git


The following commit(s) were added to refs/heads/xinyuan-stage-by-stage by this 
push:
     new 6f205a6ee5 fix
6f205a6ee5 is described below

commit 6f205a6ee5fca0eb7f4fdebe18307f7b2da97b12
Author: Xinyuan Lin <xinyu...@uci.edu>
AuthorDate: Thu Jan 22 21:03:52 2026 -0800

    fix
---
 .../main/scala/org/apache/texera/workflow/WorkflowCompiler.scala    | 6 ++----
 .../org/apache/texera/amber/core/workflow/WorkflowSettings.scala    | 4 ++--
 2 files changed, 4 insertions(+), 6 deletions(-)

diff --git 
a/amber/src/main/scala/org/apache/texera/workflow/WorkflowCompiler.scala 
b/amber/src/main/scala/org/apache/texera/workflow/WorkflowCompiler.scala
index 7f17e1aebd..b93aa3e4db 100644
--- a/amber/src/main/scala/org/apache/texera/workflow/WorkflowCompiler.scala
+++ b/amber/src/main/scala/org/apache/texera/workflow/WorkflowCompiler.scala
@@ -151,10 +151,8 @@ class WorkflowCompiler(
     val (physicalPlan, outputPortsNeedingStorage) =
       expandLogicalPlan(logicalPlan, logicalPlanPojo.opsToViewResult, None)
 
-    context.workflowSettings = WorkflowSettings(
-      context.workflowSettings.dataTransferBatchSize,
-      outputPortsNeedingStorage,
-      context.workflowSettings.executionMode
+    context.workflowSettings = context.workflowSettings.copy(
+      outputPortsNeedingStorage = outputPortsNeedingStorage
     )
 
     Workflow(context, logicalPlan, physicalPlan)
diff --git 
a/common/workflow-core/src/main/scala/org/apache/texera/amber/core/workflow/WorkflowSettings.scala
 
b/common/workflow-core/src/main/scala/org/apache/texera/amber/core/workflow/WorkflowSettings.scala
index 9f3487344a..c4a86d3538 100644
--- 
a/common/workflow-core/src/main/scala/org/apache/texera/amber/core/workflow/WorkflowSettings.scala
+++ 
b/common/workflow-core/src/main/scala/org/apache/texera/amber/core/workflow/WorkflowSettings.scala
@@ -23,7 +23,7 @@ import org.apache.texera.config.GuiConfig
 
 case class WorkflowSettings(
     dataTransferBatchSize: Int = 400,
-    outputPortsNeedingStorage: Set[GlobalPortIdentity] = Set.empty,
     executionMode: ExecutionMode =
-      ExecutionMode.valueOf(GuiConfig.guiWorkflowWorkspaceDefaultExecutionMode)
+      
ExecutionMode.valueOf(GuiConfig.guiWorkflowWorkspaceDefaultExecutionMode),
+    outputPortsNeedingStorage: Set[GlobalPortIdentity] = Set.empty
 )