[jira] [Created] (FLINK-2430) Potential race condition when restart all is called for a Twill runnable

["Henry Saputra (JIRA)" <ji...@apache.org>]

Henry Saputra created FLINK-2430:
------------------------------------

             Summary: Potential race condition when restart all is called for a Twill runnable
                 Key: FLINK-2430
                 URL: https://issues.apache.org/jira/browse/FLINK-2430
             Project: Flink
          Issue Type: Bug
    Affects Versions: 0.6-incubating
            Reporter: Henry Saputra


When sending restart instance to all for a particular TwillRunnable, it could have race condition where the heartbeat thread run right after all containers have been released which make the check:

     // Looks for containers requests.
      if (provisioning.isEmpty() && runnableContainerRequests.isEmpty() && runningContainers.isEmpty()) {
        LOG.info("All containers completed. Shutting down application master.");
        break;
      }

This could happen when all running containers are empty and new runnableContainerRequests has not been added.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)