You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by ga...@apache.org on 2012/10/05 23:44:31 UTC
svn commit: r1394829 - in /pig/trunk: CHANGES.txt
test/e2e/pig/tests/nightly.conf
Author: gates
Date: Fri Oct 5 21:44:31 2012
New Revision: 1394829
URL: http://svn.apache.org/viewvc?rev=1394829&view=rev
Log:
PIG-2932 Setting high default_parallel causes IOException in local mode
Modified:
pig/trunk/CHANGES.txt
pig/trunk/test/e2e/pig/tests/nightly.conf
Modified: pig/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/pig/trunk/CHANGES.txt?rev=1394829&r1=1394828&r2=1394829&view=diff
==============================================================================
--- pig/trunk/CHANGES.txt (original)
+++ pig/trunk/CHANGES.txt Fri Oct 5 21:44:31 2012
@@ -287,6 +287,8 @@ OPTIMIZATIONS
BUG FIXES
+PIG-2932: Setting high default_parallel causes IOException in local mode (cheolsoo via gates)
+
PIG-2737: [piggybank] TestIndexedStorage is failing, should be refactored (jcoveney)
PIG-2935: Catch NoSuchMethodError when StoreFuncInterface's new cleanupOnSuccess method isn't implemented. (gates via dvryaboy)
Modified: pig/trunk/test/e2e/pig/tests/nightly.conf
URL: http://svn.apache.org/viewvc/pig/trunk/test/e2e/pig/tests/nightly.conf?rev=1394829&r1=1394828&r2=1394829&view=diff
==============================================================================
--- pig/trunk/test/e2e/pig/tests/nightly.conf (original)
+++ pig/trunk/test/e2e/pig/tests/nightly.conf Fri Oct 5 21:44:31 2012
@@ -4980,6 +4980,7 @@ store a into ':OUTPATH:';\,
'tests' => [
{
'num' => 1,
+ 'execonly' => 'mapred',
'pig' => q\
SET default_parallel 9;
A = LOAD ':INPATH:/singlefile/prerank' using PigStorage(',') as (rownumber:long,rankcabd:long,rankbdaa:long,rankbdca:long,rankaacd:long,rankaaba:long,a:int,b:int,c:int,tail:bytearray);
@@ -4994,6 +4995,7 @@ store a into ':OUTPATH:';\,
\,
}, {
'num' => 2,
+ 'execonly' => 'mapred',
'pig' => q\
SET default_parallel 9;
A = LOAD ':INPATH:/singlefile/prerank' using PigStorage(',') as (rownumber:long,rankcabd:long,rankbdaa:long,rankbdca:long,rankaacd:long,rankaaba:long,a:int,b:int,c:int,tail:bytearray);
@@ -5008,6 +5010,7 @@ store a into ':OUTPATH:';\,
\,
}, {
'num' => 3,
+ 'execonly' => 'mapred',
'pig' => q\
SET default_parallel 7;
A = LOAD ':INPATH:/singlefile/prerank' using PigStorage(',') as (rownumber:long,rankcabd:long,rankbdaa:long,rankbdca:long,rankaacd:long,rankaaba:long,a:int,b:int,c:int,tail:bytearray);
@@ -5022,6 +5025,7 @@ store a into ':OUTPATH:';\,
\,
}, {
'num' => 4,
+ 'execonly' => 'mapred',
'pig' => q\
SET default_parallel 7;
A = LOAD ':INPATH:/singlefile/prerank' using PigStorage(',') as (rownumber:long,rankcabd:long,rankbdaa:long,rankbdca:long,rankaacd:long,rankaaba:long,a:int,b:int,c:int,tail:bytearray);
@@ -5036,6 +5040,7 @@ store a into ':OUTPATH:';\,
\,
}, {
'num' =>5,
+ 'execonly' => 'mapred',
'pig' => q\
SET default_parallel 9;
A = LOAD ':INPATH:/singlefile/prerank' using PigStorage(',') as (rownumber:long,rankcabd:long,rankbdaa:long,rankbdca:long,rankaacd:long,rankaaba:long,a:int,b:int,c:int,tail:bytearray);
@@ -5050,6 +5055,7 @@ store a into ':OUTPATH:';\,
\,
}, {
'num' =>6,
+ 'execonly' => 'mapred',
'pig' => q\
SET default_parallel 7;
A = LOAD ':INPATH:/singlefile/prerank' using PigStorage(',') as (rownumber:long,rankcabd:long,rankbdaa:long,rankbdca:long,rankaacd:long,rankaaba:long,a:int,b:int,c:int,tail:bytearray);
@@ -5064,6 +5070,7 @@ store a into ':OUTPATH:';\,
\,
}, {
'num' => 7,
+ 'execonly' => 'mapred',
'pig' => q\
SET default_parallel 7;
A = LOAD ':INPATH:/singlefile/prerank' using PigStorage(',') as (rownumber:long,rankcabd:long,rankbdaa:long,rankbdca:long,rankaacd:long,rankaaba:long,a:int,b:int,c:int,tail:bytearray);
@@ -5081,6 +5088,7 @@ store a into ':OUTPATH:';\,
\,
}, {
'num' => 8,
+ 'execonly' => 'mapred',
'pig' => q\
SET default_parallel 9;
SET pig.splitCombination false;
@@ -5105,6 +5113,7 @@ store a into ':OUTPATH:';\,
\,
}, {
'num' => 9,
+ 'execonly' => 'mapred',
'pig' => q\
SET default_parallel 25;
A = LOAD ':INPATH:/singlefile/biggish' using PigStorage(',') as (rownumber:long,idx:long,tail:bytearray);
@@ -5120,6 +5129,7 @@ store a into ':OUTPATH:';\,
\,
}, {
'num' => 10,
+ 'execonly' => 'mapred',
'pig' => q\
SET default_parallel 11;
SET pig.splitCombination false;