(texera) branch xinyuan-loop-feb updated: update

[linxinyuan]

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

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


The following commit(s) were added to refs/heads/xinyuan-loop-feb by this push:
     new a05ffd1f78 update
a05ffd1f78 is described below

commit a05ffd1f780a8c1911df7e16b408206ab3820804
Author: Xinyuan Lin <xinyu...@uci.edu>
AuthorDate: Wed Feb 11 02:06:08 2026 -0800

    update
---
 .../org/apache/texera/amber/operator/loop/LoopEndOpDesc.scala      | 7 ++++---
 .../org/apache/texera/amber/operator/loop/LoopEndOpExec.scala      | 5 +----
 2 files changed, 5 insertions(+), 7 deletions(-)

diff --git 
a/common/workflow-operator/src/main/scala/org/apache/texera/amber/operator/loop/LoopEndOpDesc.scala
 
b/common/workflow-operator/src/main/scala/org/apache/texera/amber/operator/loop/LoopEndOpDesc.scala
index 72f97f7c89..31719229f0 100644
--- 
a/common/workflow-operator/src/main/scala/org/apache/texera/amber/operator/loop/LoopEndOpDesc.scala
+++ 
b/common/workflow-operator/src/main/scala/org/apache/texera/amber/operator/loop/LoopEndOpDesc.scala
@@ -19,13 +19,14 @@
 
 package org.apache.texera.amber.operator.loop
 
-import com.fasterxml.jackson.annotation.JsonProperty
+import com.fasterxml.jackson.annotation.{JsonProperty, JsonPropertyDescription}
 import com.kjetland.jackson.jsonSchema.annotations.JsonSchemaTitle
 import org.apache.texera.amber.core.executor.OpExecWithClassName
 import org.apache.texera.amber.core.virtualidentity.{ExecutionIdentity, 
WorkflowIdentity}
 import org.apache.texera.amber.core.workflow.{InputPort, OutputPort, 
PhysicalOp}
 import org.apache.texera.amber.operator.LogicalOp
 import org.apache.texera.amber.operator.metadata.{OperatorGroupConstants, 
OperatorInfo}
+import org.apache.texera.amber.util.JSONUtils.objectMapper
 
 class LoopEndOpDesc extends LogicalOp {
 
@@ -33,7 +34,6 @@ class LoopEndOpDesc extends LogicalOp {
   @JsonSchemaTitle("Iteration Number")
   var iteration: Int = _
 
-
   override def getPhysicalOp(
       workflowId: WorkflowIdentity,
       executionId: ExecutionIdentity
@@ -43,10 +43,11 @@ class LoopEndOpDesc extends LogicalOp {
         workflowId,
         executionId,
         operatorIdentifier,
-        
OpExecWithClassName("org.apache.texera.amber.operator.loop.LoopEndOpExec")
+        
OpExecWithClassName("org.apache.texera.amber.operator.loop.LoopEndOpExec",objectMapper.writeValueAsString(this))
       )
       .withInputPorts(operatorInfo.inputPorts)
       .withOutputPorts(operatorInfo.outputPorts)
+      .withParallelizable(false)
       .withSuggestedWorkerNum(1)
   }
 
diff --git 
a/common/workflow-operator/src/main/scala/org/apache/texera/amber/operator/loop/LoopEndOpExec.scala
 
b/common/workflow-operator/src/main/scala/org/apache/texera/amber/operator/loop/LoopEndOpExec.scala
index cb9393ed4f..b1e6deace1 100644
--- 
a/common/workflow-operator/src/main/scala/org/apache/texera/amber/operator/loop/LoopEndOpExec.scala
+++ 
b/common/workflow-operator/src/main/scala/org/apache/texera/amber/operator/loop/LoopEndOpExec.scala
@@ -24,9 +24,6 @@ import org.apache.texera.amber.core.tuple.{Tuple, TupleLike}
 import org.apache.texera.amber.util.JSONUtils.objectMapper
 
 
-class LoopEndOpExec(descString: String) extends OperatorExecutor {
-  private val desc: LoopEndOpDesc = objectMapper.readValue(descString, 
classOf[LoopEndOpDesc])
-  val iteration: Int = desc.iteration
-
+class LoopEndOpExec extends OperatorExecutor {
   override def processTuple(tuple: Tuple, port: Int): Iterator[TupleLike] = 
Iterator(tuple)
 }