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 d9d0cd9438 update
d9d0cd9438 is described below

commit d9d0cd94388ef21f1e32289d8f0e5d359553443f
Author: Xinyuan Lin <[email protected]>
AuthorDate: Tue Feb 10 18:30:19 2026 -0800

    update
---
 .../engine/architecture/controller/execution/RegionExecution.scala      | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/amber/src/main/scala/org/apache/texera/amber/engine/architecture/controller/execution/RegionExecution.scala
 
b/amber/src/main/scala/org/apache/texera/amber/engine/architecture/controller/execution/RegionExecution.scala
index e905c2b044..d5939c2e3b 100644
--- 
a/amber/src/main/scala/org/apache/texera/amber/engine/architecture/controller/execution/RegionExecution.scala
+++ 
b/amber/src/main/scala/org/apache/texera/amber/engine/architecture/controller/execution/RegionExecution.scala
@@ -59,6 +59,8 @@ case class RegionExecution(region: Region) {
       physicalOpId: PhysicalOpIdentity,
       inheritOperatorExecution: Option[OperatorExecution] = None
   ): OperatorExecution = {
+    assert(!operatorExecutions.contains(physicalOpId), "OperatorExecution 
already exists.")
+
     operatorExecutions.getOrElseUpdate(
       physicalOpId,
       inheritOperatorExecution

Reply via email to