[ https://issues.apache.org/jira/browse/FLINK-4577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Tzu-Li (Gordon) Tai closed FLINK-4577. -------------------------------------- Resolution: Fixed Assignee: Tzu-Li (Gordon) Tai Fix Version/s: 1.3.0 Resolved for 1.3.0 with http://git-wip-us.apache.org/repos/asf/flink/commit/1932240. > 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 > Assignee: Tzu-Li (Gordon) Tai > Fix For: 1.3.0 > > > 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)