[ https://issues.apache.org/jira/browse/PIG-2442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Anitha Raju updated PIG-2442: ----------------------------- Description: Hi, If there are multiple store in a pig streaming script, it goes into infinite waiting. Script {code} DEFINE SCRIPT `./a.pl` SHIP ('/homes/anithar/a.pl');; DEFINE SCRIPT1 `./b.pl` SHIP ('/homes/anithar/b.pl');; A = LOAD 'test.txt' USING PigStorage() ; B1 = STREAM A THROUGH SCRIPT ; B1 = foreach B1 generate $0; STORE B1 INTO 'B1' USING PigStorage(); B2 = STREAM B1 THROUGH SCRIPT1; STORE B2 INTO 'B2' USING PigStorage(); {code} a.pl -------- #! /usr/bin/perl -w while (my $line = <STDIN>) { print uc($line); } -------- b.pl --------- #! /usr/bin/perl -w while (my $line = <STDIN>) { print $line; } --------- Input (test.txt) {code} test hi hello {code} This infinite waiting happens randomly causing the job to fail with "Task attempt failed to report status for 605 seconds. Killing!". Same happens with 0.8 version too. Regards, Anitha was: Hi, If there are multiple store in a pig streaming script, it goes into infinite waiting. Script {code} DEFINE SCRIPT `./a.pl` SHIP ('/homes/anithar/a.pl');; DEFINE SCRIPT1 `./b.pl` SHIP ('/homes/anithar/b.pl');; A = LOAD 'test.txt' USING PigStorage() ; B1 = STREAM A THROUGH SCRIPT ; B1 = foreach B1 generate $0; STORE B1 INTO 'B1' USING PigStorage(); B2 = STREAM B1 THROUGH SCRIPT1; STORE B2 INTO 'B2' USING PigStorage(); {code} a.pl -------- #! /usr/bin/perl -w while (my $line = <STDIN>) { print uc($line); } -------- b.pl --------- #! /usr/bin/perl -w while (my $line = <STDIN>) { print $line; } --------- This infinite waiting happens randomly causing the job to fail with "Task attempt failed to report status for 605 seconds. Killing!". Same happens with 0.8 version too. Regards, Anitha > Multiple Stores in pig streaming causes infinite waiting > -------------------------------------------------------- > > Key: PIG-2442 > URL: https://issues.apache.org/jira/browse/PIG-2442 > Project: Pig > Issue Type: Bug > Affects Versions: 0.8.1, 0.9.0 > Reporter: Anitha Raju > > Hi, > If there are multiple store in a pig streaming script, it goes into infinite > waiting. > Script > {code} > DEFINE SCRIPT `./a.pl` SHIP ('/homes/anithar/a.pl');; > DEFINE SCRIPT1 `./b.pl` SHIP ('/homes/anithar/b.pl');; > A = LOAD 'test.txt' USING PigStorage() ; > B1 = STREAM A THROUGH SCRIPT ; > B1 = foreach B1 generate $0; > STORE B1 INTO 'B1' USING PigStorage(); > B2 = STREAM B1 THROUGH SCRIPT1; > STORE B2 INTO 'B2' USING PigStorage(); > {code} > a.pl > -------- > #! /usr/bin/perl -w > while (my $line = <STDIN>) { > print uc($line); > } > -------- > b.pl > --------- > #! /usr/bin/perl -w > while (my $line = <STDIN>) { > print $line; > } > --------- > Input (test.txt) > {code} > test > hi > hello > {code} > This infinite waiting happens randomly causing the job to fail with "Task > attempt failed to report > status for 605 seconds. Killing!". > Same happens with 0.8 version too. > Regards, > Anitha -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa For more information on JIRA, see: http://www.atlassian.com/software/jira