(texera) branch xinyuan-state-only updated: fix: persist state in scala data processor

[linxinyuan]

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

aglinxinyuan pushed a commit to branch xinyuan-state-only
in repository https://gitbox.apache.org/repos/asf/texera.git


The following commit(s) were added to refs/heads/xinyuan-state-only by this 
push:
     new be81f7d231 fix: persist state in scala data processor
be81f7d231 is described below

commit be81f7d231696bf486a1a5f23d39d3877d540a67
Author: Xinyuan Lin <xinyu...@uci.edu>
AuthorDate: Sun Apr 19 01:32:04 2026 -0700

    fix: persist state in scala data processor
---
 .../apache/texera/amber/engine/architecture/worker/DataProcessor.scala   | 1 +
 1 file changed, 1 insertion(+)

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 3aa5fa90a4..65c560ee59 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
@@ -126,6 +126,7 @@ class DataProcessor(
       val outputState = executor.processState(state, port)
       if (outputState.isDefined) {
         outputManager.emitState(outputState.get)
+        outputManager.saveStateToStorageIfNeeded(state)
       }
     } catch safely {
       case e =>