GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/914
[taskmanager] do not process message if not connected to job manager When a message is received on the task manager, it should not be processed when not connected to the job manager. At least that is what the log message states but the message is processed anyways. This pull request changes this behavior. This commit merely includes the code that would have been executed in any case to an else block that ensures that it is only executed in case the task manager is connected. You can merge this pull request into a Git repository by running: $ git pull https://github.com/mxm/flink taskmanager-fix Alternatively you can review and apply these changes as the patch at: https://github.com/apache/flink/pull/914.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #914 ---- commit 385cac2c371b85f35e246d69fe534aeffed26999 Author: Maximilian Michels <m...@apache.org> Date: 2015-07-15T10:16:24Z [taskmanager] do not process message if not connected to job manager This commit merely includes the code that would have been executed in any case to an else block that ensures that it is only executed in case the task manager is connected. ---- --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---