(texera) branch xinyuan-input-source-operator updated: fix fmt

[linxinyuan]

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

linxinyuan pushed a commit to branch xinyuan-input-source-operator
in repository https://gitbox.apache.org/repos/asf/texera.git


The following commit(s) were added to refs/heads/xinyuan-input-source-operator 
by this push:
     new 8c6ddd0a9c fix fmt
8c6ddd0a9c is described below

commit 8c6ddd0a9c85db05b7d7d1c66b460853cecb7110
Author: Xinyuan Lin <xinyu...@uci.edu>
AuthorDate: Sun Apr 12 03:19:01 2026 -0700

    fix fmt
---
 .../amber/operator/source/scan/InputFileScanSourceOpExec.scala       | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git 
a/common/workflow-operator/src/main/scala/org/apache/texera/amber/operator/source/scan/InputFileScanSourceOpExec.scala
 
b/common/workflow-operator/src/main/scala/org/apache/texera/amber/operator/source/scan/InputFileScanSourceOpExec.scala
index 9e76710fde..8c4998e6a9 100644
--- 
a/common/workflow-operator/src/main/scala/org/apache/texera/amber/operator/source/scan/InputFileScanSourceOpExec.scala
+++ 
b/common/workflow-operator/src/main/scala/org/apache/texera/amber/operator/source/scan/InputFileScanSourceOpExec.scala
@@ -41,7 +41,8 @@ class InputFileScanSourceOpExec private[scan] (
     objectMapper.readValue(descString, classOf[InputFileScanSourceOpDesc])
 
   override def processTuple(tuple: Tuple, port: Int): Iterator[TupleLike] = {
-    val fileName = FileResolver.resolve(tuple.getFields.collectFirst { case s: 
String => s }.get).toASCIIString
+    val fileName =
+      FileResolver.resolve(tuple.getFields.collectFirst { case s: String => s 
}.get).toASCIIString
     val is: InputStream =
       DocumentFactory.openReadonlyDocument(new URI(fileName)).asInputStream()
 
@@ -125,6 +126,4 @@ class InputFileScanSourceOpExec private[scan] (
     new AutoClosingIterator(rawIterator, () => closeables.foreach(_.close()))
   }
 
-
-
 }