Update sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceb…

…erg/ScanTaskReader.java Co-authored-by: Ahmed Abualsaud <[email protected]>
apache · Jan 6, 2025 · 239aaa7 · 239aaa7
1 parent 2f0f04b
commit 239aaa7
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/ScanTaskReader.java b/sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/ScanTaskReader.java
@@ -101,7 +101,7 @@ public boolean advance() throws IOException {
     @SuppressWarnings("nullness")
     org.apache.iceberg.@NonNull Schema project = this.project;
     @Nullable
-    String nameMapping = source.getTable().properties().get(TableProperties.DEFAULT_NAME_MAPPING);
+    @Nullable String nameMapping = source.getTable().properties().get(TableProperties.DEFAULT_NAME_MAPPING);
 
     do {
       // If our current iterator is working... do that.