pig-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ga...@apache.org
Subject svn commit: r1394829 - in /pig/trunk: CHANGES.txt test/e2e/pig/tests/nightly.conf
Date Fri, 05 Oct 2012 21:44:31 GMT
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;



Mime
View raw message