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 4977837877 update
4977837877 is described below
commit 49778378773d91caa78a219e54db8b7a6ab8b729
Author: Xinyuan Lin <[email protected]>
AuthorDate: Mon Mar 16 20:33:09 2026 -0700
update
---
.../architecture/messaginglayer/OutputManager.scala | 16 ++++++++++------
1 file changed, 10 insertions(+), 6 deletions(-)
diff --git
a/amber/src/main/scala/org/apache/texera/amber/engine/architecture/messaginglayer/OutputManager.scala
b/amber/src/main/scala/org/apache/texera/amber/engine/architecture/messaginglayer/OutputManager.scala
index a018158f36..39ba67d260 100644
---
a/amber/src/main/scala/org/apache/texera/amber/engine/architecture/messaginglayer/OutputManager.scala
+++
b/amber/src/main/scala/org/apache/texera/amber/engine/architecture/messaginglayer/OutputManager.scala
@@ -236,12 +236,16 @@ class OutputManager(
}
def saveStateToStorageIfNeeded(state: State, outputPortId: Int): Unit = {
- val writer = DocumentFactory
- .createDocument(this.storageUris(outputPortId).resolve("state"),
state.schema)
- .writer(VirtualIdentityUtils.getWorkerIndex(actorId).toString)
- .asInstanceOf[BufferedItemWriter[Tuple]]
- writer.putOne(state.toTuple)
- writer.close()
+ try {
+ val writer = DocumentFactory
+ .createDocument(storageUris(outputPortId).resolve("state"),
state.schema)
+ .writer(VirtualIdentityUtils.getWorkerIndex(actorId).toString)
+ .asInstanceOf[BufferedItemWriter[Tuple]]
+ writer.putOne(state.toTuple)
+ writer.close()
+ } catch {
+ case _: Exception => ()
+ }
}
/**
