You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tez.apache.org by bi...@apache.org on 2013/10/26 04:20:02 UTC
git commit: TEZ-584.Intermittent test issue with TestGroupedSplits
(bikas)
Updated Branches:
refs/heads/master 72c3c6a01 -> 8ed793a6f
TEZ-584.Intermittent test issue with TestGroupedSplits (bikas)
Project: http://git-wip-us.apache.org/repos/asf/incubator-tez/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tez/commit/8ed793a6
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tez/tree/8ed793a6
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tez/diff/8ed793a6
Branch: refs/heads/master
Commit: 8ed793a6feac01d964bd6c2caee4e43adc42d8a7
Parents: 72c3c6a
Author: Bikas Saha <bi...@apache.org>
Authored: Fri Oct 25 19:16:13 2013 -0700
Committer: Bikas Saha <bi...@apache.org>
Committed: Fri Oct 25 19:16:13 2013 -0700
----------------------------------------------------------------------
.../org/apache/hadoop/mapred/split/TestGroupedSplits.java | 9 ++++++---
1 file changed, 6 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-tez/blob/8ed793a6/tez-mapreduce/src/test/java/org/apache/hadoop/mapred/split/TestGroupedSplits.java
----------------------------------------------------------------------
diff --git a/tez-mapreduce/src/test/java/org/apache/hadoop/mapred/split/TestGroupedSplits.java b/tez-mapreduce/src/test/java/org/apache/hadoop/mapred/split/TestGroupedSplits.java
index 35c88cb..f913b13 100644
--- a/tez-mapreduce/src/test/java/org/apache/hadoop/mapred/split/TestGroupedSplits.java
+++ b/tez-mapreduce/src/test/java/org/apache/hadoop/mapred/split/TestGroupedSplits.java
@@ -239,9 +239,12 @@ public class TestGroupedSplits {
for (int j=1; j<=3; ++j) {
format.setDesiredNumberOfSPlits(j);
InputSplit[] splits = format.getSplits(job, 100);
- Assert.assertEquals("compressed splits == " + j, j, splits.length);
- // j==3 cases exercises the code where desired == actual
- // and does not do grouping
+ if (j==1 || j==3) {
+ // j==1 covers single split corner case
+ // j==3 cases exercises the code where desired == actual
+ // and does not do grouping
+ Assert.assertEquals("compressed splits == " + j, j, splits.length);
+ }
List<Text> results = new ArrayList<Text>();
for (int i=0; i<splits.length; ++i) {
List<Text> read = readSplit(format, splits[i], job);