[
https://issues.apache.org/jira/browse/FLINK-13662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16975031#comment-16975031
]
Franz Thoma commented on FLINK-13662:
-
The test heavily depends on the {{processElem
[
https://issues.apache.org/jira/browse/FLINK-13662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16911288#comment-16911288
]
Franz Thoma commented on FLINK-13662:
-
I did a quick check, there don't seem to be a
Franz Thoma created FLINK-9686:
--
Summary: Flink Kinesis Producer: Enable Kinesis authentication via
AssumeRole
Key: FLINK-9686
URL: https://issues.apache.org/jira/browse/FLINK-9686
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-9374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Franz Thoma updated FLINK-9374:
---
Description:
The {{FlinkKinesisProducer}} just accepts records and forwards it to a
{{KinesisProducer
Franz Thoma created FLINK-9374:
--
Summary: Flink Kinesis Producer does not backpressure
Key: FLINK-9374
URL: https://issues.apache.org/jira/browse/FLINK-9374
Project: Flink
Issue Type: Bug