[
https://issues.apache.org/jira/browse/FLINK-4194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370997#comment-16370997
]
Cristian commented on FLINK-4194:
---------------------------------
Hi guys. This is a feature we miss.
Given the fact that it's not implemented and will likely not be implemented in
the near future... how else could this be done right now?
Let me explain. Right now I need to run flink applications that read from
Kinesis for a specific period of time (say two days), and I'm trying to figure
out a way for the Flink app to gracefully stop itself after that. Is there a
way to achieve that right now from within the Flink app?
My other option, which I'd like to avoid, is to periodically check for flink
apps to kill from an external worker.
> Implement isEndOfStream() for KinesisDeserializationSchema
> ----------------------------------------------------------
>
> Key: FLINK-4194
> URL: https://issues.apache.org/jira/browse/FLINK-4194
> Project: Flink
> Issue Type: New Feature
> Components: Kinesis Connector
> Reporter: Robert Metzger
> Assignee: Tzu-Li (Gordon) Tai
> Priority: Major
>
> **Original JIRA title: KinesisDeserializationSchema.isEndOfStream() is never
> called. The corresponding part of the code has been commented out with
> reference to this JIRA.**
> 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
(v7.6.3#76005)
