Check nullability in CheckpointEntryIterator

trinodb · May 27, 2022 · 2db4430 · 2db4430
1 parent 429464c
commit 2db4430
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/...ain/java/io/trino/plugin/deltalake/transactionlog/checkpoint/CheckpointEntryIterator.java b/...ain/java/io/trino/plugin/deltalake/transactionlog/checkpoint/CheckpointEntryIterator.java
@@ -532,16 +532,19 @@ private String getString(Block block, int position)
 
     private long getLong(Block block, int position)
     {
+        checkArgument(!block.isNull(position));
         return block.getLong(position, 0);
     }
 
     private int getInt(Block block, int position)
     {
+        checkArgument(!block.isNull(position));
         return block.getInt(position, 0);
     }
 
     private byte getByte(Block block, int position)
     {
+        checkArgument(!block.isNull(position));
         return block.getByte(position, 0);
     }