(beam) branch master updated: Don't prematurely close FileIO (#37626)

[ahmedabualsaud]

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

ahmedabualsaud pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new 1ee2c717f3e Don't prematurely close FileIO (#37626)
1ee2c717f3e is described below

commit 1ee2c717f3eec5d15e28bc18640bacc3d4c2a3ca
Author: Ahmed Abualsaud <65791736+ahmedab...@users.noreply.github.com>
AuthorDate: Tue Feb 17 20:34:49 2026 -0500

    Don't prematurely close FileIO (#37626)
---
 .../main/java/org/apache/beam/sdk/io/iceberg/ReadUtils.java    | 10 +++-------
 1 file changed, 3 insertions(+), 7 deletions(-)

diff --git 
a/sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/ReadUtils.java
 
b/sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/ReadUtils.java
index 4b127fcdef2..a4d95ca249b 100644
--- 
a/sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/ReadUtils.java
+++ 
b/sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/ReadUtils.java
@@ -48,7 +48,6 @@ import org.apache.iceberg.expressions.Evaluator;
 import org.apache.iceberg.expressions.Expression;
 import org.apache.iceberg.hadoop.HadoopInputFile;
 import org.apache.iceberg.io.CloseableIterable;
-import org.apache.iceberg.io.FileIO;
 import org.apache.iceberg.io.InputFile;
 import org.apache.iceberg.mapping.NameMapping;
 import org.apache.iceberg.mapping.NameMappingParser;
@@ -74,12 +73,9 @@ public class ReadUtils {
 
   static ParquetReader<Record> createReader(FileScanTask task, Table table, 
Schema schema) {
     String filePath = task.file().path().toString();
-    InputFile inputFile;
-    try (FileIO io = table.io()) {
-      EncryptedInputFile encryptedInput =
-          EncryptedFiles.encryptedInput(io.newInputFile(filePath), 
task.file().keyMetadata());
-      inputFile = table.encryption().decrypt(encryptedInput);
-    }
+    EncryptedInputFile encryptedInput =
+        EncryptedFiles.encryptedInput(table.io().newInputFile(filePath), 
task.file().keyMetadata());
+    InputFile inputFile = table.encryption().decrypt(encryptedInput);
     Map<Integer, ?> idToConstants =
         ReadUtils.constantsMap(task, 
IdentityPartitionConverters::convertConstant, table.schema());