[
https://issues.apache.org/jira/browse/FLINK-4194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15376674#comment-15376674
]
Robert Metzger commented on FLINK-4194:
---------------------------------------
I'm not planning to work on this one in the near future :)
I know that the {{isEndOfStream()}} method is implemented differently in the
two Kafka consumers. I agree that the {{FlinkKafkaConsumer09}} behavior is more
reasonable. The Kinesis consumer should behave in the same fashion (stopping
the consumption on all shards).
Since there is no communication between the parallel consumer instances, the
behavior of the {{isEndOfStream()}} method is not really defined anyways, and
the method needs to be implemented in a way that it stops all parallel
instances / shards / partitions.
> KinesisDeserializationSchema.isEndOfStream() is never called
> ------------------------------------------------------------
>
> Key: FLINK-4194
> URL: https://issues.apache.org/jira/browse/FLINK-4194
> Project: Flink
> Issue Type: Sub-task
> Components: Kinesis Connector
> Affects Versions: 1.1.0
> Reporter: Robert Metzger
>
> The Kinesis connector does not respect the
> {{KinesisDeserializationSchema.isEndOfStream()}} method.
> The purpose of this method is to stop consuming from a source, based on input
> data.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
