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 <[email protected]>
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 [email protected] or file a JIRA ticket
with INFRA.
---
