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
index c9906618a64d..8cab5eeb6658 100644
--- 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.