diff --git a/hadoop-ozone/ozonefs-common/src/main/java/org/apache/hadoop/fs/ozone/BasicRootedOzoneClientAdapterImpl.java b/hadoop-ozone/ozonefs-common/src/main/java/org/apache/hadoop/fs/ozone/BasicRootedOzoneClientAdapterImpl.java index 0079e5b39dbc..c19eb142e20a 100644 --- a/hadoop-ozone/ozonefs-common/src/main/java/org/apache/hadoop/fs/ozone/BasicRootedOzoneClientAdapterImpl.java +++ b/hadoop-ozone/ozonefs-common/src/main/java/org/apache/hadoop/fs/ozone/BasicRootedOzoneClientAdapterImpl.java @@ -379,8 +379,8 @@ public InputStream readFile(String pathStr) throws IOException { config); String key = ofsPath.getKeyName(); try { - OzoneBucket bucket = getBucket(ofsPath, false); - return bucket.readFile(key).getInputStream(); + ClientProtocol clientProtocol = ozoneClient.getProxy(); + return clientProtocol.readFile(ofsPath.getVolumeName(), ofsPath.getBucketName(), key).getInputStream(); } catch (OMException ex) { if (ex.getResult() == OMException.ResultCodes.FILE_NOT_FOUND || ex.getResult() == OMException.ResultCodes.KEY_NOT_FOUND