[
https://issues.apache.org/jira/browse/FLINK-4577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15892066#comment-15892066
]
ASF GitHub Bot commented on FLINK-4577:
---------------------------------------
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
----
> Re-enable transparent reshard handling in Kinesis Consumer
> ----------------------------------------------------------
>
> Key: FLINK-4577
> URL: https://issues.apache.org/jira/browse/FLINK-4577
> Project: Flink
> Issue Type: Task
> Components: Kinesis Connector
> Reporter: Tzu-Li (Gordon) Tai
>
> In FLINK-4341, we disabled transparent reshard handling in the Kinesis
> consumer as a short-term workaround before FLINK-4576 comes around.
> This ticket tracks the progress of re-enabling it again, by implementing a
> {{LowWatermarkListener}} interface as described in FLINK-4576.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
