Estou executando o Apache Pig .11.1 com o Hadoop 2.0.5.

A maioria dos trabalhos simples que eu executo no Pig funcionam perfeitamente bem.

No entanto, sempre que tento usar GROUP BY em um conjunto de dados grande ou no operador LIMIT, recebo esses erros de conexão:

2013-07-29 13:24:08,591 [main] INFO  org.apache.hadoop.mapred.ClientServiceDelegate - Application state is completed. FinalApplicationStatus=SUCCEEDED. Redirecting to job history server 
013-07-29 11:57:29,421 [main] INFO  org.apache.hadoop.ipc.Client - Retrying connect to server: 0.0.0.0/0.0.0.0:10020. Already tried 0 time(s); retry policy is RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1 SECONDS)

2013-07-29 11:57:30,421 [main] INFO  org.apache.hadoop.ipc.Client - Retrying connect to server: 0.0.0.0/0.0.0.0:10020. Already tried 1 time(s); retry policy is RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1 SECONDS)

2013-07-29 11:57:31,422 [main] INFO  org.apache.hadoop.ipc.Client - Retrying connect to server: 0.0.0.0/0.0.0.0:10020. Already tried 2 time(s); retry policy is RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1 SECONDS)
...
2013-07-29 13:24:18,597 [main] INFO  org.apache.hadoop.ipc.Client - Retrying connect to server: 0.0.0.0/0.0.0.0:10020. Already tried 9 time(s); retry policy is RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1 SECONDS)
2013-07-29 13:24:18,598 [main] ERROR org.apache.hadoop.security.UserGroupInformation - PriviledgedActionException as:gpadmin (auth:SIMPLE) cause:java.io.IOException

O estranho é que, após esses erros aparecerem por cerca de 2 minutos, eles param e a saída correta aparece na parte inferior.

Portanto, o Hadoop está funcionando bem e calculando a saída adequada. O problema é apenas esses erros de conexão que continuam aparecendo.

oLIMIT operador sempre recebe esse erro. Isso acontece no modo MapReduce e no modo local. oGROUP BY operador funcionará bem em pequenos conjuntos de dados.

Uma coisa que notei é que sempre que esse erro aparece, o trabalho criava e executava vários arquivos JAR durante o trabalho. No entanto, depois de alguns minutos dessas mensagens aparecendo, a saída correta finalmente aparece.

Alguma sugestão sobre como se livrar dessas mensagens?