parquet-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From b...@apache.org
Subject git commit: PARQUET-59: Fix parquet-scrooge test on hadoop-2.
Date Tue, 05 Aug 2014 02:04:35 GMT
Repository: incubator-parquet-mr
Updated Branches:
  refs/heads/master 014845517 -> 3a396d3a4


PARQUET-59: Fix parquet-scrooge test on hadoop-2.

Author: Ryan Blue <rblue@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 <rblue@cloudera.com>
Authored: Mon Aug 4 19:04:18 2014 -0700
Committer: Ryan Blue <rblue@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()) {


Mime
View raw message