You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@parquet.apache.org by bl...@apache.org on 2014/08/05 04:04:35 UTC
git commit: PARQUET-59: Fix parquet-scrooge test on hadoop-2.
Repository: incubator-parquet-mr
Updated Branches:
refs/heads/master 014845517 -> 3a396d3a4
PARQUET-59: Fix parquet-scrooge test on hadoop-2.
Author: Ryan Blue <rb...@cloudera.com>
Closes #27 from rdblue/PARQUET-59-fix-scrooge-test-on-hadoop-2 and squashes the following commits:
ac34369 [Ryan Blue] PARQUET-59: Fix parquet-scrooge test on hadoop-2.
Project: http://git-wip-us.apache.org/repos/asf/incubator-parquet-mr/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-parquet-mr/commit/3a396d3a
Tree: http://git-wip-us.apache.org/repos/asf/incubator-parquet-mr/tree/3a396d3a
Diff: http://git-wip-us.apache.org/repos/asf/incubator-parquet-mr/diff/3a396d3a
Branch: refs/heads/master
Commit: 3a396d3a4000bd2575e5314cdea0ba1e2367804c
Parents: 0148455
Author: Ryan Blue <rb...@cloudera.com>
Authored: Mon Aug 4 19:04:18 2014 -0700
Committer: Ryan Blue <rb...@cloudera.com>
Committed: Mon Aug 4 19:04:18 2014 -0700
----------------------------------------------------------------------
.../src/test/java/parquet/scrooge/ParquetScroogeSchemeTest.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-parquet-mr/blob/3a396d3a/parquet-scrooge/src/test/java/parquet/scrooge/ParquetScroogeSchemeTest.java
----------------------------------------------------------------------
diff --git a/parquet-scrooge/src/test/java/parquet/scrooge/ParquetScroogeSchemeTest.java b/parquet-scrooge/src/test/java/parquet/scrooge/ParquetScroogeSchemeTest.java
index de74bb7..399ff61 100644
--- a/parquet-scrooge/src/test/java/parquet/scrooge/ParquetScroogeSchemeTest.java
+++ b/parquet-scrooge/src/test/java/parquet/scrooge/ParquetScroogeSchemeTest.java
@@ -97,10 +97,10 @@ public class ParquetScroogeSchemeTest {
job.setInputFormatClass(ParquetThriftInputFormat.class);
ParquetThriftInputFormat.setInputPaths(job, parquetFile);
final JobID jobID = new JobID("local", 1);
- List<InputSplit> splits = parquetScroogeInputFormat.getSplits(new JobContext(ContextUtil.getConfiguration(job), jobID));
+ List<InputSplit> splits = parquetScroogeInputFormat.getSplits(ContextUtil.newJobContext(ContextUtil.getConfiguration(job), jobID));
T readValue = null;
for (InputSplit split : splits) {
- TaskAttemptContext taskAttemptContext = new TaskAttemptContext(ContextUtil.getConfiguration(job), new TaskAttemptID(new TaskID(jobID, true, 1), 0));
+ TaskAttemptContext taskAttemptContext = ContextUtil.newTaskAttemptContext(ContextUtil.getConfiguration(job), new TaskAttemptID(new TaskID(jobID, true, 1), 0));
final RecordReader<Void, T> reader = parquetScroogeInputFormat.createRecordReader(split, taskAttemptContext);
reader.initialize(split, taskAttemptContext);
if (reader.nextKeyValue()) {