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?
---