GitHub user tzulitai opened a pull request:
https://github.com/apache/flink/pull/3458
[FLINK-4577] [kinesis] Transparent reshard handling for FlinkKinesisConsumer
This PR uses the new `SourceFunction.SourceContext#markAsTemporarilyIdle()`
to let the Flink Kinesis Consumer handle reshards transparently (i.e., without
the need to fail and restart the job when a Kinesis reshard operation occurs).
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/tzulitai/flink FLINK-4577
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/3458.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 #3458
----
commit 60f1a715c220cfb31a22b5812942dc44a9b42652
Author: Tzu-Li (Gordon) Tai <[email protected]>
Date: 2017-03-02T10:56:39Z
[FLINK-4577] [kinesis] Transparent reshard handling for FlinkKinesisConsumer
----
---
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.
---
