[
https://issues.apache.org/jira/browse/FLINK-4194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334318#comment-17334318
]
Flink Jira Bot commented on FLINK-4194:
---
This issue was marked "stale-assigned" and has not
[
https://issues.apache.org/jira/browse/FLINK-4194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17323712#comment-17323712
]
Flink Jira Bot commented on FLINK-4194:
---
This issue is assigned but has not received an update in 7
[
https://issues.apache.org/jira/browse/FLINK-4194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370997#comment-16370997
]
Cristian commented on FLINK-4194:
-
Hi guys. This is a feature we miss.
Given the fact that it's not
[
https://issues.apache.org/jira/browse/FLINK-4194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572052#comment-15572052
]
Robert Metzger commented on FLINK-4194:
---
The method {{KinesisDeserializationSchema.isEndOfStream}}
[
https://issues.apache.org/jira/browse/FLINK-4194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15461269#comment-15461269
]
Tzu-Li (Gordon) Tai commented on FLINK-4194:
On second thought, I think we ought to discuss
[
https://issues.apache.org/jira/browse/FLINK-4194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15443628#comment-15443628
]
Tzu-Li (Gordon) Tai commented on FLINK-4194:
I'll implement {{isEndOfShard()}} as an initial
