From 017003fd19c9eacbf9f69327e6ec589384f58e1b Mon Sep 17 00:00:00 2001 From: kunal642 Date: Mon, 25 Mar 2019 13:45:23 +0530 Subject: [PATCH] Fix show/drop cache test case(windows) --- .../spark/sql/execution/command/cache/CacheUtil.scala | 6 ++++++ 1 file changed, 6 insertions(+) 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 } }