GitHub user kl0u opened a pull request:
https://github.com/apache/flink/pull/2245
[hotfix] Fix Redis Sink to fail at opening if Redis is not initialized.
Before if Redis was not initialized, the job would start and would wait
until the first element arrives in order to realize that Redis is not running.
This fixes that by checking the connection to redis during the opening phase.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/kl0u/flink redis_check
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/2245.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 #2245
----
commit 9a31902de93732d2e3c39d3e23ed3e34162795ec
Author: kl0u <kklou...@gmail.com>
Date: 2016-07-13T16:40:17Z
[hotfix] Fix Redis Sink to fail at opening if Redis is not initialized.
----
---
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.
---
