[jira] [Created] (FLINK-9694) potentially NPE in CompositeTypeSerializerConfigSnapshot constructor

vinoyang created FLINK-9694: --- Summary: potentially NPE in CompositeTypeSerializerConfigSnapshot constructor Key: FLINK-9694 URL: https://issues.apache.org/jira/browse/FLINK-9694 Project: Flink Iss

[jira] [Created] (FLINK-9693) possible memory link in jobmanager retaining archived checkpoints

Steven Zhen Wu created FLINK-9693: - Summary: possible memory link in jobmanager retaining archived checkpoints Key: FLINK-9693 URL: https://issues.apache.org/jira/browse/FLINK-9693 Project: Flink

[jira] [Created] (FLINK-9692) Adapt maxRecords parameter in the getRecords call to optimize bytes read from Kinesis

Lakshmi Rao created FLINK-9692: -- Summary: Adapt maxRecords parameter in the getRecords call to optimize bytes read from Kinesis Key: FLINK-9692 URL: https://issues.apache.org/jira/browse/FLINK-9692 Proj

[DISCUSS] Feature freeze for Flink 1.6

Dear community, as discussed in the Flink 1.6 feature thread [1], the proposed release date of *end of July* for Flink 1.6 is getting closer. Since we need a release manager I would first of all volunteer for it. With Flink 1.5, the community invested a lot of time into release and test automatio

Re: Consuming data from dynamoDB streams to flink

Hi Gordon: Really appreciate the reply. Yes our plan is to build the connector on top of the FlinkKinesisConsumer. At the high level, FlinkKinesisConsumer mainly interacts with Kinesis through the AmazonKinesis client, more specifically through the following three function calls: - describeSt