This is an automated email from the ASF dual-hosted git repository.
linxinyuan pushed a commit to branch xinyuan-cm-for-loop
in repository https://gitbox.apache.org/repos/asf/texera.git
The following commit(s) were added to refs/heads/xinyuan-cm-for-loop by this
push:
new 4b28412223 fix fmt
4b28412223 is described below
commit 4b2841222306fb069c7d597853ea5aaf602e2113
Author: Xinyuan Lin <[email protected]>
AuthorDate: Sat Jan 24 21:57:32 2026 -0800
fix fmt
---
.../scala/org/apache/texera/amber/operator/loop/LoopEndOpDesc.scala | 2 +-
.../scala/org/apache/texera/amber/operator/loop/LoopStartOpDesc.scala | 2 +-
2 files changed, 2 insertions(+), 2 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 0657c6ce42..f56068e903 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
@@ -35,7 +35,7 @@ class LoopEndOpDesc extends LogicalOp {
workflowId,
executionId,
operatorIdentifier,
- OpExecWithClassName("org.apache.amber.operator.loop.LoopEndOpExec")
+
OpExecWithClassName("org.apache.texera.amber.operator.loop.LoopEndOpExec")
)
.withInputPorts(operatorInfo.inputPorts)
.withOutputPorts(operatorInfo.outputPorts)
diff --git
a/common/workflow-operator/src/main/scala/org/apache/texera/amber/operator/loop/LoopStartOpDesc.scala
b/common/workflow-operator/src/main/scala/org/apache/texera/amber/operator/loop/LoopStartOpDesc.scala
index fa52f68278..d0c30256f3 100644
---
a/common/workflow-operator/src/main/scala/org/apache/texera/amber/operator/loop/LoopStartOpDesc.scala
+++
b/common/workflow-operator/src/main/scala/org/apache/texera/amber/operator/loop/LoopStartOpDesc.scala
@@ -44,7 +44,7 @@ class LoopStartOpDesc extends LogicalOp {
executionId,
operatorIdentifier,
OpExecWithClassName(
- "org.apache.amber.operator.loop.LoopStartOpExec",
+ "org.apache.texera.amber.operator.loop.LoopStartOpExec",
objectMapper.writeValueAsString(this)
)
)