(texera) branch xinyuan-cm-for-loop-mat-dcm updated: update

[linxinyuan]

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

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


The following commit(s) were added to refs/heads/xinyuan-cm-for-loop-mat-dcm by 
this push:
     new 9899d08b48 update
9899d08b48 is described below

commit 9899d08b48a16038bc61b6891f0661e93f7274d7
Author: Xinyuan Lin <xinyu...@uci.edu>
AuthorDate: Wed Feb 4 18:15:17 2026 -0800

    update
---
 .../texera/amber/engine/architecture/worker/DataProcessor.scala      | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git 
a/amber/src/main/scala/org/apache/texera/amber/engine/architecture/worker/DataProcessor.scala
 
b/amber/src/main/scala/org/apache/texera/amber/engine/architecture/worker/DataProcessor.scala
index adbc97bfe4..13f0b17de4 100644
--- 
a/amber/src/main/scala/org/apache/texera/amber/engine/architecture/worker/DataProcessor.scala
+++ 
b/amber/src/main/scala/org/apache/texera/amber/engine/architecture/worker/DataProcessor.scala
@@ -172,8 +172,9 @@ class DataProcessor(
           PORT_ALIGNMENT,
           EndIterationRequest(worker)
         )
-        outputManager.ECMWriterThreads(portId).putOne(new 
Tuple(ResultSchema.ecmSchema, Array(worker.name)))
-        outputManager.ECMWriterThreads(portId).close()
+        val writer = outputManager.ECMWriterThreads(portId)
+        writer.putOne(new Tuple(ResultSchema.ecmSchema, Array(worker.name)))
+        writer.close()
         outputManager.closeOutputStorageWriterIfNeeded(portId)
         
asyncRPCClient.controllerInterface.iterationCompleted(IterationCompletedRequest(portId),
 asyncRPCClient.mkContext(CONTROLLER))
         executor.reset()