diff --git a/presto-hive/src/main/java/com/facebook/presto/hive/GenericHiveRecordCursorProvider.java b/presto-hive/src/main/java/com/facebook/presto/hive/GenericHiveRecordCursorProvider.java
index daff1dabb0979..33884407d955f 100644
--- a/presto-hive/src/main/java/com/facebook/presto/hive/GenericHiveRecordCursorProvider.java
+++ b/presto-hive/src/main/java/com/facebook/presto/hive/GenericHiveRecordCursorProvider.java
@@ -72,16 +72,16 @@ public Optional<RecordCursor> createRecordCursor(
 
         RecordReader<?, ?> recordReader = hdfsEnvironment.doAs(session.getUser(),
                 () -> HiveUtil.createRecordReader(configuration, path, start, length, schema, columns, customSplitInfo));
-
-        return Optional.of(new GenericHiveRecordCursor<>(
-                configuration,
-                path,
-                genericRecordReader(recordReader),
-                length,
-                schema,
-                columns,
-                hiveStorageTimeZone,
-                typeManager));
+        return hdfsEnvironment.doAs(session.getUser(),
+                () -> Optional.of(new GenericHiveRecordCursor<>(
+                        configuration,
+                        path,
+                        genericRecordReader(recordReader),
+                        length,
+                        schema,
+                        columns,
+                        hiveStorageTimeZone,
+                        typeManager)));
     }
 
     @SuppressWarnings("unchecked")