|
@@ -109,7 +109,10 @@ public class LogCLIHelpers implements Configurable {
|
|
remoteRootLogDir, appId, user, logDirSuffix);
|
|
remoteRootLogDir, appId, user, logDirSuffix);
|
|
RemoteIterator<FileStatus> nodeFiles;
|
|
RemoteIterator<FileStatus> nodeFiles;
|
|
try {
|
|
try {
|
|
- nodeFiles = FileContext.getFileContext().listStatus(remoteAppLogDir);
|
|
|
|
|
|
+ Path qualifiedLogDir =
|
|
|
|
+ FileContext.getFileContext(getConf()).makeQualified(remoteAppLogDir);
|
|
|
|
+ nodeFiles = FileContext.getFileContext(qualifiedLogDir.toUri(),
|
|
|
|
+ getConf()).listStatus(remoteAppLogDir);
|
|
} catch (FileNotFoundException fnf) {
|
|
} catch (FileNotFoundException fnf) {
|
|
System.out.println("Logs not available at " + remoteAppLogDir.toString());
|
|
System.out.println("Logs not available at " + remoteAppLogDir.toString());
|
|
System.out
|
|
System.out
|