[jira] [Created] (TEZ-3980) ShuffleRunner: the wake loop needs to check for shutdown

[Gopal V (JIRA)]

Gopal V created TEZ-3980:
----------------------------

             Summary: ShuffleRunner: the wake loop needs to check for shutdown
                 Key: TEZ-3980
                 URL: https://issues.apache.org/jira/browse/TEZ-3980
             Project: Apache Tez
          Issue Type: Bug
            Reporter: Gopal V


In the ShuffleRunner threads, there's a loop which does not terminate if the 
task threads get killed.

{code}
          while ((runningFetchers.size() >= numFetchers || 
pendingHosts.isEmpty())
              && numCompletedInputs.get() < numInputs) {
            inputContext.notifyProgress();
            boolean ret = wakeLoop.await(1000, TimeUnit.MILLISECONDS);
          }
{code}

The wakeLoop signal does not exit this out of the loop and is missing a break 
for shut-down.




--
This message was sent by Atlassian JIRA
(v7.6.3#76005)