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 1173dd4599 fix fmt
1173dd4599 is described below
commit 1173dd4599d6ad5a3ac4f30a5f2f4d1a515e66c9
Author: Xinyuan Lin <[email protected]>
AuthorDate: Sun Apr 19 16:07:45 2026 -0700
fix fmt
---
.../core/storage/runnables/input_port_materialization_reader_runnable.py | 1 -
1 file changed, 1 deletion(-)
diff --git
a/amber/src/main/python/core/storage/runnables/input_port_materialization_reader_runnable.py
b/amber/src/main/python/core/storage/runnables/input_port_materialization_reader_runnable.py
index 493ecf0a41..a600f87857 100644
---
a/amber/src/main/python/core/storage/runnables/input_port_materialization_reader_runnable.py
+++
b/amber/src/main/python/core/storage/runnables/input_port_materialization_reader_runnable.py
@@ -172,7 +172,6 @@ class InputPortMaterializationReaderRunnable(Runnable,
Stoppable):
tup.cast_to_schema(self.tuple_schema)
for data_frame in self.tuple_to_batch_with_filter(tup):
self.emit_payload(data_frame)
-
self.emit_ecm("EndChannel",
EmbeddedControlMessageType.PORT_ALIGNMENT)
self._finished = True
except Exception as err:
