diff --git a/plugin/trino-hive/src/main/java/io/trino/plugin/hive/GenericHiveRecordCursor.java b/plugin/trino-hive/src/main/java/io/trino/plugin/hive/GenericHiveRecordCursor.java index 8ac0b6a7cb22..e67c25cd8136 100644 --- a/plugin/trino-hive/src/main/java/io/trino/plugin/hive/GenericHiveRecordCursor.java +++ b/plugin/trino-hive/src/main/java/io/trino/plugin/hive/GenericHiveRecordCursor.java @@ -217,11 +217,14 @@ public boolean advanceNextPosition() return false; } - // reset loaded flags - Arrays.fill(loaded, false); + // Only deserialize the value if atleast one column is required + if (types.length > 0) { + // reset loaded flags + Arrays.fill(loaded, false); - // decode value - rowData = deserializer.deserialize(value); + // decode value + rowData = deserializer.deserialize(value); + } return true; }