diff --git a/presto-hive/src/main/java/io/prestosql/plugin/hive/BackgroundHiveSplitLoader.java b/presto-hive/src/main/java/io/prestosql/plugin/hive/BackgroundHiveSplitLoader.java index b6a32c5a8..05340684f 100644 --- a/presto-hive/src/main/java/io/prestosql/plugin/hive/BackgroundHiveSplitLoader.java +++ b/presto-hive/src/main/java/io/prestosql/plugin/hive/BackgroundHiveSplitLoader.java @@ -257,7 +257,7 @@ public class BackgroundHiveSplitLoader ListenableFuture future; taskExecutionLock.readLock().lock(); try { - future = loadSplits(); + future = hdfsEnvironment.doAs(hdfsContext.getIdentity().getUser(), () -> loadSplits()); } catch (Exception e) { if (e instanceof IOException) {