diff --git a/integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/cache/CacheUtil.scala b/integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/cache/CacheUtil.scala index 615d8e0b7f8..18402e9f639 100644 --- a/integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/cache/CacheUtil.scala +++ b/integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/cache/CacheUtil.scala @@ -44,6 +44,9 @@ object CacheUtil { CarbonDataMergerUtil.getValidSegmentList(absoluteTableIdentifier).asScala.flatMap { segment => segment.getCommittedIndexFile.keySet().asScala + }.map { indexFile => + indexFile.replace(CarbonCommonConstants.WINDOWS_FILE_SEPARATOR, + CarbonCommonConstants.FILE_SEPARATOR) }.toList } else { val tablePath = carbonTable.getTablePath @@ -53,6 +56,9 @@ object CacheUtil { load => val seg = new Segment(load.getLoadName, null, readCommittedScope) seg.getCommittedIndexFile.keySet().asScala + }.map { indexFile => + indexFile.replace(CarbonCommonConstants.WINDOWS_FILE_SEPARATOR, + CarbonCommonConstants.FILE_SEPARATOR) }.toList } }