Repository: phoenix Updated Branches: refs/heads/4.14-HBase-1.3 82ec54fd6 -> f5ce8f7d6
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/f5ce8f7d Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/f5ce8f7d Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/f5ce8f7d Branch: refs/heads/4.14-HBase-1.3 Commit: f5ce8f7d61895f7d9dabd13469d07a6dfd176ba4 Parents: 82ec54f Author: 492066199 <[email protected]> Authored: Fri Jul 6 10:45:38 2018 +0800 Committer: Vincent Poon <[email protected]> Committed: Fri Aug 3 10:44:53 2018 -0400 ---------------------------------------------------------------------- .../org/apache/phoenix/iterate/TableSnapshotResultIterator.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/phoenix/blob/f5ce8f7d/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);
