Github user mohammadshahidkhan commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2387#discussion_r197014465
--- Diff:
core/src/main/java/org/apache/carbondata/core/util/CarbonProperties.java ---
@@ -1530,6 +1531,22 @@ public String getSystemFolderLocation() {
if (systemLocation == null) {
systemLocation = getStorePath();
}
+ // append the HDFS uri to the system folder if not already added.
+ systemLocation =
CarbonUtil.checkAndAppendFileSystemURIScheme(systemLocation);
+ FileFactory.FileType fileType =
FileFactory.getFileType(systemLocation);
+ switch (fileType) {
+ case HDFS:
+ case VIEWFS:
+ case ALLUXIO:
+ break;
+ case LOCAL:
+ // for local fs remove the URI scheme and unify the path
representation
+ systemLocation = FileFactory.getUpdatedFilePath(systemLocation);
+ break;
+ default:
+ // for local fs remove the URI scheme and unify the path
representation
+ systemLocation = FileFactory.getUpdatedFilePath(systemLocation);
+ }
--- End diff --
Thanks @manishgupta88 , missed to to check the internal implementation of
FileFactory.getUpdatedFilePath().
---
