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.9.0, 0.8.1 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; } --------- 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