Github user ravipesala commented on a diff in the pull request: https://github.com/apache/carbondata/pull/2161#discussion_r185778044 --- Diff: core/src/main/java/org/apache/carbondata/core/datastore/impl/FileFactory.java --- @@ -365,10 +366,11 @@ public static boolean createNewLockFile(String filePath, FileType fileType) thro public static String getUpdatedFilePath(String filePath, FileType fileType) { switch (fileType) { case HDFS: - case ALLUXIO: case VIEWFS: case S3: return filePath; + case ALLUXIO: + return StringUtils.containsAny(filePath,"alluxio")?filePath: "alluxio://"+filePath; --- End diff -- Why is this special handling for alluxio?
---