PHOENIX-4797 file not found or file exist exception when create global index use -snapshot option
Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/13014204 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/13014204 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/13014204 Branch: refs/heads/omid2 Commit: 13014204dd753324379ad300084b09b43158bd95 Parents: 26d2460 Author: 492066199 <[email protected]> Authored: Fri Jul 6 10:45:38 2018 +0800 Committer: Karan Mehta <[email protected]> Committed: Tue Jul 24 21:47:16 2018 -0700 ---------------------------------------------------------------------- .../org/apache/phoenix/iterate/TableSnapshotResultIterator.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/phoenix/blob/13014204/phoenix-core/src/main/java/org/apache/phoenix/iterate/TableSnapshotResultIterator.java ---------------------------------------------------------------------- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/iterate/TableSnapshotResultIterator.java b/phoenix-core/src/main/java/org/apache/phoenix/iterate/TableSnapshotResultIterator.java index df60339..016d3be 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/iterate/TableSnapshotResultIterator.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/iterate/TableSnapshotResultIterator.java @@ -39,6 +39,7 @@ import java.util.ArrayList; import java.util.Collections; import java.util.Iterator; import java.util.List; +import java.util.UUID; public class TableSnapshotResultIterator implements ResultIterator { @@ -65,7 +66,8 @@ public class TableSnapshotResultIterator implements ResultIterator { this.scan = scan; this.scanMetricsHolder = scanMetricsHolder; this.scanIterator = UNINITIALIZED_SCANNER; - this.restoreDir = new Path(configuration.get(PhoenixConfigurationUtil.RESTORE_DIR_KEY)); + this.restoreDir = new Path(configuration.get(PhoenixConfigurationUtil.RESTORE_DIR_KEY), + UUID.randomUUID().toString()); this.snapshotName = configuration.get( PhoenixConfigurationUtil.SNAPSHOT_NAME_KEY); this.rootDir = FSUtils.getRootDir(configuration);
