Repository: phoenix Updated Branches: refs/heads/4.x-HBase-1.1 c2d2ed5d8 -> 87d455f47
Revert "PHOENIX-4141 Fix flapping TableSnapshotReadsMapReduceIT" This reverts commit 089863a7368e5f70afc8fc7f1048d15372ffaf1c. Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/147d22d4 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/147d22d4 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/147d22d4 Branch: refs/heads/4.x-HBase-1.1 Commit: 147d22d4ccd46496efa3f0bed9a3930c78222173 Parents: c2d2ed5 Author: Samarth Jain <[email protected]> Authored: Sat Sep 2 15:46:52 2017 -0700 Committer: Samarth Jain <[email protected]> Committed: Sat Sep 2 15:46:52 2017 -0700 ---------------------------------------------------------------------- .../apache/phoenix/end2end/TableSnapshotReadsMapReduceIT.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/phoenix/blob/147d22d4/phoenix-core/src/it/java/org/apache/phoenix/end2end/TableSnapshotReadsMapReduceIT.java ---------------------------------------------------------------------- diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/TableSnapshotReadsMapReduceIT.java b/phoenix-core/src/it/java/org/apache/phoenix/end2end/TableSnapshotReadsMapReduceIT.java index 063de5f..92a2bda 100644 --- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/TableSnapshotReadsMapReduceIT.java +++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/TableSnapshotReadsMapReduceIT.java @@ -89,7 +89,7 @@ public class TableSnapshotReadsMapReduceIT extends ParallelStatsDisabledIT { // configure Phoenix M/R job to read snapshot final Configuration conf = getUtility().getConfiguration(); Job job = Job.getInstance(conf); - Path tmpDir = new Path("/tmp"); + Path tmpDir = getUtility().getDataTestDir(SNAPSHOT_NAME); PhoenixMapReduceUtil.setInput(job, PhoenixIndexDBWritable.class, SNAPSHOT_NAME, tableName, tmpDir, null, FIELD1, FIELD2, FIELD3); @@ -109,7 +109,7 @@ public class TableSnapshotReadsMapReduceIT extends ParallelStatsDisabledIT { // configure Phoenix M/R job to read snapshot final Configuration conf = getUtility().getConfiguration(); Job job = Job.getInstance(conf); - Path tmpDir = new Path("/tmp"); + Path tmpDir = getUtility().getDataTestDir(SNAPSHOT_NAME); PhoenixMapReduceUtil.setInput(job, PhoenixIndexDBWritable.class, SNAPSHOT_NAME, tableName, tmpDir, FIELD3 + " > 0001", FIELD1, FIELD2, FIELD3); @@ -129,7 +129,7 @@ public class TableSnapshotReadsMapReduceIT extends ParallelStatsDisabledIT { // configure Phoenix M/R job to read snapshot final Configuration conf = getUtility().getConfiguration(); Job job = Job.getInstance(conf); - Path tmpDir = new Path("/tmp"); + Path tmpDir = getUtility().getDataTestDir(SNAPSHOT_NAME); // Running limit with order by on non pk column String inputQuery = "SELECT * FROM " + tableName + " ORDER BY FIELD2 LIMIT 1"; PhoenixMapReduceUtil.setInput(job, PhoenixIndexDBWritable.class, SNAPSHOT_NAME, tableName,
