You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by da...@apache.org on 2014/04/03 23:42:30 UTC
svn commit: r1584412 - in /pig/branches/tez/test/e2e/pig:
drivers/TestDriverPig.pm tests/bigdata.conf tests/cmdline.conf
tests/grunt.conf tests/hcat.conf tests/multiquery.conf tests/negative.conf
tests/streaming.conf
Author: daijy
Date: Thu Apr 3 21:42:30 2014
New Revision: 1584412
URL: http://svn.apache.org/r1584412
Log:
PIG-3863: e2e tests run all tests even execonly flag does not match
Modified:
pig/branches/tez/test/e2e/pig/drivers/TestDriverPig.pm
pig/branches/tez/test/e2e/pig/tests/bigdata.conf
pig/branches/tez/test/e2e/pig/tests/cmdline.conf
pig/branches/tez/test/e2e/pig/tests/grunt.conf
pig/branches/tez/test/e2e/pig/tests/hcat.conf
pig/branches/tez/test/e2e/pig/tests/multiquery.conf
pig/branches/tez/test/e2e/pig/tests/negative.conf
pig/branches/tez/test/e2e/pig/tests/streaming.conf
Modified: pig/branches/tez/test/e2e/pig/drivers/TestDriverPig.pm
URL: http://svn.apache.org/viewvc/pig/branches/tez/test/e2e/pig/drivers/TestDriverPig.pm?rev=1584412&r1=1584411&r2=1584412&view=diff
==============================================================================
--- pig/branches/tez/test/e2e/pig/drivers/TestDriverPig.pm (original)
+++ pig/branches/tez/test/e2e/pig/drivers/TestDriverPig.pm Thu Apr 3 21:42:30 2014
@@ -1005,7 +1005,7 @@ sub wrongExecutionMode($$)
if (defined $testCmd->{'execonly'}) {
my @exectypes = split(',', $testCmd->{'execonly'});
- if (!$testCmd->{'exectype'} ~~ @exectypes) {
+ if (!grep /$testCmd->{'exectype'}/, @exectypes) {
print $log "Skipping test $testCmd->{'group'}" . "_" .
$testCmd->{'num'} . " since it is executed only in " .
$testCmd->{'execonly'} . " mode and we are executing in " .
Modified: pig/branches/tez/test/e2e/pig/tests/bigdata.conf
URL: http://svn.apache.org/viewvc/pig/branches/tez/test/e2e/pig/tests/bigdata.conf?rev=1584412&r1=1584411&r2=1584412&view=diff
==============================================================================
--- pig/branches/tez/test/e2e/pig/tests/bigdata.conf (original)
+++ pig/branches/tez/test/e2e/pig/tests/bigdata.conf Thu Apr 3 21:42:30 2014
@@ -24,8 +24,7 @@
$cfg = {
'driver' => 'Pig',
- 'execonly' => 'mapred',
- 'execonly' => 'mapred',
+ 'execonly' => 'mapred,tez',
'groups' => [
{
Modified: pig/branches/tez/test/e2e/pig/tests/cmdline.conf
URL: http://svn.apache.org/viewvc/pig/branches/tez/test/e2e/pig/tests/cmdline.conf?rev=1584412&r1=1584411&r2=1584412&view=diff
==============================================================================
--- pig/branches/tez/test/e2e/pig/tests/cmdline.conf (original)
+++ pig/branches/tez/test/e2e/pig/tests/cmdline.conf Thu Apr 3 21:42:30 2014
@@ -254,7 +254,7 @@ dump A;\,
{
'name' => 'Warning',
'floatpostprocess' => 0,
- 'execonly' => 'mapred', # Warnings use counters, which don't work in local mode
+ 'execonly' => 'mapred,tez', # Warnings use counters, which don't work in local mode
'delimiter' => ' ',
'tests' => [
Modified: pig/branches/tez/test/e2e/pig/tests/grunt.conf
URL: http://svn.apache.org/viewvc/pig/branches/tez/test/e2e/pig/tests/grunt.conf?rev=1584412&r1=1584411&r2=1584412&view=diff
==============================================================================
--- pig/branches/tez/test/e2e/pig/tests/grunt.conf (original)
+++ pig/branches/tez/test/e2e/pig/tests/grunt.conf Thu Apr 3 21:42:30 2014
@@ -43,7 +43,7 @@ $cfg = {
},{
'num' => 2,
'pig' => "pwd",
- 'execonly' => 'mapred', # don't have a clue what their cwd will be for local mode
+ 'execonly' => 'mapred,tez', # don't have a clue what their cwd will be for local mode
'expected_out_regex' => "hdfs:",
'rc' => 0
Modified: pig/branches/tez/test/e2e/pig/tests/hcat.conf
URL: http://svn.apache.org/viewvc/pig/branches/tez/test/e2e/pig/tests/hcat.conf?rev=1584412&r1=1584411&r2=1584412&view=diff
==============================================================================
--- pig/branches/tez/test/e2e/pig/tests/hcat.conf (original)
+++ pig/branches/tez/test/e2e/pig/tests/hcat.conf Thu Apr 3 21:42:30 2014
@@ -24,7 +24,7 @@
$cfg = {
'driver' => 'Pig',
- 'execonly' => 'mapred',
+ 'execonly' => 'mapred,tez',
'groups' => [
{
Modified: pig/branches/tez/test/e2e/pig/tests/multiquery.conf
URL: http://svn.apache.org/viewvc/pig/branches/tez/test/e2e/pig/tests/multiquery.conf?rev=1584412&r1=1584411&r2=1584412&view=diff
==============================================================================
--- pig/branches/tez/test/e2e/pig/tests/multiquery.conf (original)
+++ pig/branches/tez/test/e2e/pig/tests/multiquery.conf Thu Apr 3 21:42:30 2014
@@ -378,7 +378,7 @@ $cfg = {
# Streaming in demux
{
'num' => 20,
- 'execonly' => 'mapred',
+ 'execonly' => 'mapred,tez',
'pig' => q#
define CMD `perl GroupBy.pl '\t' 0` ship(':SCRIPTHOMEPATH:/GroupBy.pl');
A = load ':INPATH:/singlefile/studenttab10k';
@@ -396,7 +396,7 @@ $cfg = {
# Streaming in nested demux
{
'num' => 21,
- 'execonly' => 'mapred',
+ 'execonly' => 'mapred,tez',
'pig' => q#
define CMD `perl GroupBy.pl '\t' 0` ship(':SCRIPTHOMEPATH:/GroupBy.pl');
A = load ':INPATH:/singlefile/studenttab10k';
Modified: pig/branches/tez/test/e2e/pig/tests/negative.conf
URL: http://svn.apache.org/viewvc/pig/branches/tez/test/e2e/pig/tests/negative.conf?rev=1584412&r1=1584411&r2=1584412&view=diff
==============================================================================
--- pig/branches/tez/test/e2e/pig/tests/negative.conf (original)
+++ pig/branches/tez/test/e2e/pig/tests/negative.conf Thu Apr 3 21:42:30 2014
@@ -312,7 +312,7 @@ dump B;#,
{
# Define uses using non-existent command (autoship)
'num' => 1,
- 'execonly' => 'mapred',
+ 'execonly' => 'mapred,tez',
'java_params' => ['-Dopt.fetch=false'],
'pig' => q\
define CMD `perl PigStreamingNotThere.pl`;
@@ -411,7 +411,7 @@ dump B;\,
# Streaming application fails in the beginning of processing
# NEED TO CHECK STDERR MANUALLY FOR NOW
'num' => 1,
- 'execonly' => 'mapred',
+ 'execonly' => 'mapred,tez',
'pig' => q\
define CMD `perl PigStreamingBad.pl start` ship(':SCRIPTHOMEPATH:/PigStreamingBad.pl') stderr('CMD' limit 1);
A = load ':INPATH:/singlefile/studenttab10k';
@@ -423,7 +423,7 @@ store B into ':OUTPATH:';\,
# Streaming application fails in the middle of processing
# NEED TO CHECK STDERR MANUALLY FOR NOW
'num' => 2,
- 'execonly' => 'mapred',
+ 'execonly' => 'mapred,tez',
'pig' => q\
define CMD `perl PigStreamingBad.pl middle` ship(':SCRIPTHOMEPATH:/PigStreamingBad.pl') stderr('CMD' limit 1);
A = load ':INPATH:/singlefile/studenttab10k';
@@ -436,7 +436,7 @@ store B into ':OUTPATH:';\,
# bring logs to dfs
# NEED TO CHECK STDERR MANUALLY FOR NOW
'num' => 3,
- 'execonly' => 'mapred',
+ 'execonly' => 'mapred,tez',
'pig' => q\
define CMD `perl PigStreamingBad.pl end` ship(':SCRIPTHOMEPATH:/PigStreamingBad.pl') stderr('CMD' limit 1);
A = load ':INPATH:/singlefile/studenttab10k';
@@ -449,7 +449,7 @@ store B into ':OUTPATH:';\,
# bring logs to dfs
# NEED TO CHECK STDERR MANUALLY FOR NOW
'num' => 4,
- 'execonly' => 'mapred',
+ 'execonly' => 'mapred,tez',
'pig' => q\
define CMD `perl DieRandomly.pl 10000 2` ship(':SCRIPTHOMEPATH:/DieRandomly.pl') stderr('CMD' limit 1);
A = load ':INPATH:/singlefile/studenttab10k';
@@ -466,7 +466,7 @@ store B into ':OUTPATH:';\,
{
# Invalid deserializer - throws exception
'num' => 1,
- 'execonly' => 'mapred',
+ 'execonly' => 'mapred,tez',
'pig' => q\
register :FUNCPATH:/testudf.jar;
define CMD `perl PigStreaming.pl` input(stdin) output(stdout using org.apache.pig.test.udf.streaming.DumpStreamerBad) ship(':SCRIPTHOMEPATH:/PigStreaming.pl');
@@ -478,7 +478,7 @@ store B into ':OUTPATH:';\,
{
# Invalid serializer - throws exception
'num' => 2,
- 'execonly' => 'mapred',
+ 'execonly' => 'mapred,tez',
'pig' => q\
define CMD `perl PigStreamingDepend.pl` input(stdin using StringStoreBad) ship(':SCRIPTHOMEPATH:/PigStreamingDepend.pl', ':SCRIPTHOMEPATH:/PigStreamingModule.pm');
A = load ':INPATH:/singlefile/studenttab10k';
Modified: pig/branches/tez/test/e2e/pig/tests/streaming.conf
URL: http://svn.apache.org/viewvc/pig/branches/tez/test/e2e/pig/tests/streaming.conf?rev=1584412&r1=1584411&r2=1584412&view=diff
==============================================================================
--- pig/branches/tez/test/e2e/pig/tests/streaming.conf (original)
+++ pig/branches/tez/test/e2e/pig/tests/streaming.conf Thu Apr 3 21:42:30 2014
@@ -79,7 +79,7 @@ store C into ':OUTPATH:';#,
{
#Section 1.1: perl script, no parameters, autoship(Section 2.1)
'num' => 4,
- 'execonly' => 'mapred',
+ 'execonly' => 'mapred,tez',
'pig' => q#
A = load ':INPATH:/singlefile/studenttab10k';
B = foreach A generate $0, $1, $2;
@@ -90,7 +90,7 @@ store C into ':OUTPATH:';#,
{
# Section 1.2: perl script that takes parameters; explicit ship of script (Section 2.1)
'num' => 5,
- 'execonly' => 'mapred',
+ 'execonly' => 'mapred,tez',
'pig' => q#
define CMD `perl PigStreaming.pl - -` ship(':SCRIPTHOMEPATH:/PigStreaming.pl') stderr('CMD' limit 1);
A = load ':INPATH:/singlefile/studenttab10k';
@@ -102,7 +102,7 @@ store C into ':OUTPATH:';#,
{
# Section 1.3: define clause; explicit ship of script (Section 2.1)
'num' => 6,
- 'execonly' => 'mapred',
+ 'execonly' => 'mapred,tez',
'pig' => q#
define CMD `perl PigStreaming.pl` ship(':SCRIPTHOMEPATH:/PigStreaming.pl') stderr('CMD');
A = load ':INPATH:/singlefile/studenttab10k';
@@ -115,7 +115,7 @@ store D into ':OUTPATH:';#,
{
# Section 1.4: grouped data
'num' => 7,
- 'execonly' => 'mapred',
+ 'execonly' => 'mapred,tez',
'pig' => q#
define CMD `perl GroupBy.pl '\t' 0` ship(':SCRIPTHOMEPATH:/GroupBy.pl');
A = load ':INPATH:/singlefile/studenttab10k';
@@ -128,7 +128,7 @@ store D into ':OUTPATH:';#,
{
# Section 1.4: grouped and ordered data
'num' => 8,
- 'execonly' => 'mapred',
+ 'execonly' => 'mapred,tez',
'pig' => q#
define CMD `perl GroupBy.pl '\t' 0 1` ship(':SCRIPTHOMEPATH:/GroupBy.pl');
A = load ':INPATH:/singlefile/studenttab10k';
@@ -144,7 +144,7 @@ store E into ':OUTPATH:';#,
{
# Section 1.5: multiple streaming operators - adjacent - map side
'num' => 9,
- 'execonly' => 'mapred',
+ 'execonly' => 'mapred,tez',
'pig' => q#
define CMD `perl PigStreamingDepend.pl` input(stdin) ship(':SCRIPTHOMEPATH:/PigStreamingDepend.pl', ':SCRIPTHOMEPATH:/PigStreamingModule.pm');
A = load ':INPATH:/singlefile/studenttab10k';
@@ -157,7 +157,7 @@ store D into ':OUTPATH:';#,
{
# Section 1.5: multiple streaming operators - not adjacent - map side
'num' => 10,
- 'execonly' => 'mapred',
+ 'execonly' => 'mapred,tez',
'pig' => q#
A = load ':INPATH:/singlefile/studenttab10k';
define CMD `perl PigStreamingDepend.pl` input(stdin) ship(':SCRIPTHOMEPATH:/PigStreamingDepend.pl', ':SCRIPTHOMEPATH:/PigStreamingModule.pm');
@@ -172,7 +172,7 @@ store E into ':OUTPATH:';#,
{
# Section 1.5: multiple streaming operators - adjacent - reduce side
'num' => 11,
- 'execonly' => 'mapred',
+ 'execonly' => 'mapred,tez',
'pig' => q#
define CMD1 `perl GroupBy.pl '\t' 0 1` ship(':SCRIPTHOMEPATH:/GroupBy.pl') stderr('CMD1');
define CMD2 `perl PigStreamingDepend.pl` input(stdin) ship(':SCRIPTHOMEPATH:/PigStreamingDepend.pl', ':SCRIPTHOMEPATH:/PigStreamingModule.pm') stderr('CMD2');
@@ -191,7 +191,7 @@ store F into ':OUTPATH:';#,
# Section 1.5: multiple streaming operators - one on map and one on reduce side
# same alias name
'num' => 12,
- 'execonly' => 'mapred',
+ 'execonly' => 'mapred,tez',
'pig' => q#
define CMD1 `perl GroupBy.pl '\t' 0` ship(':SCRIPTHOMEPATH:/GroupBy.pl');
define CMD2 `perl PigStreamingDepend.pl` input(stdin) ship(':SCRIPTHOMEPATH:/PigStreamingDepend.pl', ':SCRIPTHOMEPATH:/PigStreamingModule.pm');
@@ -206,7 +206,7 @@ store B into ':OUTPATH:';#,
{
# Section 1.5: multiple streaming operators - adjacent - map side
'num' => 13,
- 'execonly' => 'mapred',
+ 'execonly' => 'mapred,tez',
'pig' => q#
define CMD `perl PigStreamingDepend.pl` input(stdin) ship(':SCRIPTHOMEPATH:/PigStreamingDepend.pl', ':SCRIPTHOMEPATH:/PigStreamingModule.pm');
A = load ':INPATH:/singlefile/studenttab10k';
@@ -232,7 +232,7 @@ store D into ':OUTPATH:';#,
# Section 2.1: perl script and its dependency shipped
# Also covers part of section 3.1: custom serializer
'num' => 1,
- 'execonly' => 'mapred',
+ 'execonly' => 'mapred,tez',
'pig' => q#
define CMD `perl PigStreamingDepend.pl` input(stdin) ship(':SCRIPTHOMEPATH:/PigStreamingDepend.pl', ':SCRIPTHOMEPATH:/PigStreamingModule.pm');
A = load ':INPATH:/singlefile/studenttab10k';
@@ -243,7 +243,7 @@ store B into ':OUTPATH:';#,
{
# Section 2.1: perl script and supported data file is shipped
'num' => 2,
- 'execonly' => 'mapred',
+ 'execonly' => 'mapred,tez',
'pig' => q#
define CMD `perl PigStreaming.pl - - nameMap` ship(':SCRIPTHOMEPATH:/PigStreaming.pl', ':SCRIPTHOMEPATH:/nameMap');
A = load ':INPATH:/singlefile/studenttab10k';
@@ -257,7 +257,7 @@ store E into ':OUTPATH:';#,
{
# Section 2.2: script is shipped while the supporting file is cached
'num' => 3,
- 'execonly' => 'mapred',
+ 'execonly' => 'mapred,tez',
'pig' => q@
define CMD `perl PigStreaming.pl - - nameMap` ship(':SCRIPTHOMEPATH:/PigStreaming.pl') cache(':INPATH:/nameMap/part-00000#nameMap');
A = load ':INPATH:/singlefile/studenttab10k';
@@ -283,7 +283,7 @@ store E into ':OUTPATH:';@,
{
# Section 3.1: use of custom deserializer
'num' => 1,
- 'execonly' => 'mapred',
+ 'execonly' => 'mapred,tez',
'pig' => q#
define CMD `perl PigStreaming.pl` output(stdout) ship(':SCRIPTHOMEPATH:/PigStreaming.pl');
A = load ':INPATH:/singlefile/studenttab10k';
@@ -294,7 +294,7 @@ store B into ':OUTPATH:';#,
{
# Section 3.1: use of custom serializer and deserializer
'num' => 2,
- 'execonly' => 'mapred',
+ 'execonly' => 'mapred,tez',
'pig' => q#
register :FUNCPATH:/testudf.jar;
define CMD `perl PigStreaming.pl` input(stdin using org.apache.pig.test.udf.streaming.StreamingDump) output(stdout using org.apache.pig.test.udf.streaming.DumpStreamer) ship(':SCRIPTHOMEPATH:/PigStreaming.pl');
@@ -307,7 +307,7 @@ store C into ':OUTPATH:';#,
{
# Section 3.3: streaming application reads from file rather than stdin
'num' => 3,
- 'execonly' => 'mapred',
+ 'execonly' => 'mapred,tez',
'pig' => q#
define CMD `perl PigStreaming.pl foo -` input('foo') ship(':SCRIPTHOMEPATH:/PigStreaming.pl');
A = load ':INPATH:/singlefile/studenttab10k';
@@ -318,7 +318,7 @@ store B into ':OUTPATH:';#,
{
# Section 3.4: streaming application writes single output to a file
'num' => 4,
- 'execonly' => 'mapred',
+ 'execonly' => 'mapred,tez',
'pig' => q#
define CMD `perl PigStreaming.pl - foo nameMap` output('foo') ship(':SCRIPTHOMEPATH:/PigStreaming.pl', ':SCRIPTHOMEPATH:/nameMap');
A = load ':INPATH:/singlefile/studenttab10k';
@@ -330,7 +330,7 @@ store C into ':OUTPATH:';#,
{
# Section 3.4: streaming application writes multiple outputs to file
'num' => 5,
- 'execonly' => 'mapred',
+ 'execonly' => 'mapred,tez',
'pig' => q#
define CMD `perl PigStreamingDepend.pl - sio_5_1 sio_5_2` input(stdin) output('sio_5_1', 'sio_5_2') ship(':SCRIPTHOMEPATH:/PigStreamingDepend.pl', ':SCRIPTHOMEPATH:/PigStreamingModule.pm');
A = load ':INPATH:/singlefile/studenttab10k';
@@ -341,7 +341,7 @@ store B into ':OUTPATH:';#,
{
# Section 3.4: streaming application writes multiple outputs: 1 to file and 1 to stdout
'num' => 6,
- 'execonly' => 'mapred',
+ 'execonly' => 'mapred,tez',
'pig' => q#
define CMD `perl PigStreamingDepend.pl - - sio_5_2` input(stdin) output(stdout, 'sio_5_2') ship(':SCRIPTHOMEPATH:/PigStreamingDepend.pl', ':SCRIPTHOMEPATH:/PigStreamingModule.pm');
A = load ':INPATH:/singlefile/studenttab10k';
@@ -362,7 +362,7 @@ store B into ':OUTPATH:';#,
{
# Section 4.3: integration with parameter substitition
'num' => 1,
- 'execonly' => 'mapred',
+ 'execonly' => 'mapred,tez',
'pig_params' => ['-p', qq(script_name='PigStreaming.pl')],
'pig' => q#
define CMD `perl $script_name - - nameMap` ship(':SCRIPTHOMEPATH:/$script_name', ':SCRIPTHOMEPATH:/nameMap');
@@ -387,7 +387,7 @@ store E into ':OUTPATH:';#,
{
# Section 5.1: load/store optimization
'num' => 1,
- 'execonly' => 'mapred',
+ 'execonly' => 'mapred,tez',
'pig' => q#
define CMD `perl PigStreaming.pl` ship(':SCRIPTHOMEPATH:/PigStreaming.pl') stderr('CMD');
A = load ':INPATH:/singlefile/studenttab10k';
@@ -413,7 +413,7 @@ store D into ':OUTPATH:';#,
{
# PIG-272: problem with optimization and intermediate store
'num' => 3,
- 'execonly' => 'mapred',
+ 'execonly' => 'mapred,tez',
'pig' => q#
define CMD1 `perl -ne 'print $_;print STDERR "stderr $_";'`;
define CMD2 `Split.pl 3` input(stdin using PigStreaming(',')) ship(':SCRIPTHOMEPATH:/Split.pl');
@@ -427,7 +427,7 @@ store D into ':OUTPATH:';#,
{
# PIG-272: problem with optimization and intermediate store
'num' => 4,
- 'execonly' => 'mapred',
+ 'execonly' => 'mapred,tez',
'pig' => q#
define CMD1 `perl -ne 'print $_;'`;
define CMD2 `Split.pl 3` input(stdin using PigStreaming(',')) ship(':SCRIPTHOMEPATH:/Split.pl');
@@ -445,7 +445,7 @@ store E into ':OUTPATH:';#,
# Make sure join with stream optimization works
# optimization only on load side
'num' => 5,
- 'execonly' => 'mapred',
+ 'execonly' => 'mapred,tez',
'pig' => q#
A = load ':INPATH:/singlefile/studenttab10k';
B = stream A through `cat` as (name:chararray, age:int, gpa:double);
@@ -458,7 +458,7 @@ store D into ':OUTPATH:';#,
# Make sure join with stream optimization works
# optimization only on store side
'num' => 6,
- 'execonly' => 'mapred',
+ 'execonly' => 'mapred,tez',
'pig' => q#
A = load ':INPATH:/singlefile/studenttab10k';
B = filter A by $1 > 25;
@@ -473,7 +473,7 @@ store D into ':OUTPATH:';#,
# Make sure join with stream optimization works
# optimization on load and store
'num' => 7,
- 'execonly' => 'mapred',
+ 'execonly' => 'mapred,tez',
'pig' => q#
A = load ':INPATH:/singlefile/studenttab10k';
B = stream A through `cat` as (name:chararray, age:int, gpa:double);
@@ -509,7 +509,7 @@ store B into ':OUTPATH:';#,
# case where binary finishes normally
# BEFORE all input has been passed to it
'num' => 2,
- 'execonly' => 'mapred',
+ 'execonly' => 'mapred,tez',
'pig' => q#
define CMD `perl DieRandomly.pl 10000 0` ship(':SCRIPTHOMEPATH:/DieRandomly.pl');
A = load ':INPATH:/singlefile/studenttab10k';
@@ -538,7 +538,7 @@ store D into ':OUTPATH:';#,
# BEFORE all input has been passed to it
# FIXME: in local mode
'num' => 4,
- 'execonly' => 'mapred',
+ 'execonly' => 'mapred,tez',
'pig' => q#
A = load ':INPATH:/singlefile/studenttab10k' as (name, age, gpa);
B = stream A through `head -1` as (name, age, gpa);
@@ -554,7 +554,7 @@ store E into ':OUTPATH:';#,
# BEFORE all input has been passed to it
# and emits no output
'num' => 5,
- 'execonly' => 'mapred',
+ 'execonly' => 'mapred,tez',
'pig' => q#
define CMD `perl DieRandomly.pl 10000 0` ship(':SCRIPTHOMEPATH:/DieRandomly.pl');
A = load ':INPATH:/singlefile/studenttab10k' as (name, age, gpa);
@@ -571,7 +571,7 @@ store D into ':OUTPATH:';#,
# BEFORE all input has been passed to it
# and emits no output
'num' => 6,
- 'execonly' => 'mapred',
+ 'execonly' => 'mapred,tez',
'pig' => q#
define CMD `perl DieRandomly.pl 10000 0` ship(':SCRIPTHOMEPATH:/DieRandomly.pl');
A = load ':INPATH:/singlefile/studenttab10k' as (name, age, gpa);
@@ -586,7 +586,7 @@ store E into ':OUTPATH:';#,
# two stream operators one after another where first
# one emits no output
'num' => 7,
- 'execonly' => 'mapred',
+ 'execonly' => 'mapred,tez',
'pig' => q#
define CMD `perl DieRandomly.pl 10000 0` ship(':SCRIPTHOMEPATH:/DieRandomly.pl');
A = load ':INPATH:/singlefile/studenttab10k' as (name, age, gpa);