Repository: phoenix Updated Branches: refs/heads/4.x-cdh5.11 3987c1230 -> 283c92b23
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/283c92b2 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/283c92b2 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/283c92b2 Branch: refs/heads/4.x-cdh5.11 Commit: 283c92b23db2904ce80b86f7e4fcd173bb8f6a54 Parents: 3987c12 Author: 492066199 <[email protected]> Authored: Fri Jul 6 10:45:38 2018 +0800 Committer: Karan Mehta <[email protected]> Committed: Tue Jul 24 21:49:53 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/283c92b2/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);
