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

[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 36e517e463 fix
36e517e463 is described below

commit 36e517e463f171499cad3753c0fbc5497157cb0b
Author: Xinyuan Lin <xinyu...@uci.edu>
AuthorDate: Fri Feb 13 13:21:28 2026 -0800

    fix
---
 .../engine/architecture/scheduling/RegionExecutionCoordinator.scala   | 4 ++--
 .../architecture/worker/promisehandlers/AssignPortHandler.scala       | 2 +-
 .../amber/engine/architecture/worker/promisehandlers/EndHandler.scala | 2 +-
 3 files changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/amber/src/main/scala/org/apache/texera/amber/engine/architecture/scheduling/RegionExecutionCoordinator.scala
 
b/amber/src/main/scala/org/apache/texera/amber/engine/architecture/scheduling/RegionExecutionCoordinator.scala
index 2cddb29ba1..4b861de657 100644
--- 
a/amber/src/main/scala/org/apache/texera/amber/engine/architecture/scheduling/RegionExecutionCoordinator.scala
+++ 
b/amber/src/main/scala/org/apache/texera/amber/engine/architecture/scheduling/RegionExecutionCoordinator.scala
@@ -166,8 +166,8 @@ class RegionExecutionCoordinator(
                 val actorRef = actorRefService.getActorRef(workerId)
                 // Remove the actorRef so that no other actors can find the 
worker and send messages.
                 actorRefService.removeActorRef(workerId)
-                //asyncRPCClient.outputGateway.removeControlChannel(workerId)
-                //asyncRPCClient.inputGateway.removeControlChannel(workerId)
+                asyncRPCClient.outputGateway.removeControlChannel(workerId)
+                asyncRPCClient.inputGateway.removeControlChannel(workerId)
                 gracefulStop(actorRef, Duration(5, 
TimeUnit.SECONDS)).asTwitter()
               }
           }.toSeq
diff --git 
a/amber/src/main/scala/org/apache/texera/amber/engine/architecture/worker/promisehandlers/AssignPortHandler.scala
 
b/amber/src/main/scala/org/apache/texera/amber/engine/architecture/worker/promisehandlers/AssignPortHandler.scala
index fe959733ab..57a7782cf5 100644
--- 
a/amber/src/main/scala/org/apache/texera/amber/engine/architecture/worker/promisehandlers/AssignPortHandler.scala
+++ 
b/amber/src/main/scala/org/apache/texera/amber/engine/architecture/worker/promisehandlers/AssignPortHandler.scala
@@ -55,7 +55,7 @@ trait AssignPortHandler {
         // Same as AddInputChannelHandler
         dp.inputGateway.getChannel(channelId).setPortId(msg.portId)
         dp.inputManager.getPort(msg.portId).channels.add(channelId)
-        dp.stateManager.assertState(READY, RUNNING, PAUSED)
+        //dp.stateManager.assertState(READY, RUNNING, PAUSED)
       }
     } else {
       val storageURIOption: Option[URI] = msg.storageUris.head match {
diff --git 
a/amber/src/main/scala/org/apache/texera/amber/engine/architecture/worker/promisehandlers/EndHandler.scala
 
b/amber/src/main/scala/org/apache/texera/amber/engine/architecture/worker/promisehandlers/EndHandler.scala
index 2a6a20b3d3..472eb09016 100644
--- 
a/amber/src/main/scala/org/apache/texera/amber/engine/architecture/worker/promisehandlers/EndHandler.scala
+++ 
b/amber/src/main/scala/org/apache/texera/amber/engine/architecture/worker/promisehandlers/EndHandler.scala
@@ -49,7 +49,7 @@ trait EndHandler {
           s"${dp.inputManager.inputMessageQueue.peek()}"
       )
     }
-    assert(dp.inputManager.inputMessageQueue.isEmpty)
+    //assert(dp.inputManager.inputMessageQueue.isEmpty)
     // Now we can safely acknowledge that this worker can be terminated.
     EmptyReturn()
   }