[
https://issues.apache.org/jira/browse/FLINK-2430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Henry Saputra closed FLINK-2430.
--------------------------------
Resolution: Invalid
Pop sorry wrong project =(
> 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)
