get raw filesystem should consider CachingFileSystem
*/
package com.facebook.presto.hive;
+import com.facebook.presto.cache.CachingFileSystem;
import com.facebook.presto.common.block.Block;
import com.facebook.presto.common.type.BigintType;
import com.facebook.presto.common.type.BooleanType;
@@ -405,6 +406,9 @@ public final class HiveWriteUtils
if (fileSystem instanceof HadoopExtendedFileSystem) {
return getRawFileSystem(((HadoopExtendedFileSystem) fileSystem).getRawFileSystem());
}
+ if (fileSystem instanceof CachingFileSystem) {
+ return getRawFileSystem(((CachingFileSystem) fileSystem).getDataTier());
+ }
return fileSystem;
}
