[
https://issues.apache.org/jira/browse/FLINK-18483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-18483:
----------------------------------
Summary: [EFO] Test coverage improvements for FlinkKinesisConsumer (was:
[EFO] Test coverage improvements for existing connector)
> [EFO] Test coverage improvements for FlinkKinesisConsumer
> ----------------------------------------------------------
>
> Key: FLINK-18483
> URL: https://issues.apache.org/jira/browse/FLINK-18483
> Project: Flink
> Issue Type: Sub-task
> Components: Connectors / Kinesis
> Reporter: Danny Cranmer
> Priority: Major
>
> *Background*
> EFO will refactor the existing Polling implementation to use the proposed
> {{RecordPublisher}} interface. In order to increase our confidence with this
> change, we should increase test coverage of the existing implementation.
> *Scope*
> Improved test coverage for existing Polling consumption implementation:
> # Add tests for consumption of aggregated records
> # Resuming consumption from an aggregated sub-sequence number
> # Add assertions on {{ShardIteratorType}} for existing {{ShardConsumerTest}}
> methods
> Source code will not be modified, only test code.
> *Result*
> **All existing and new tests should pass.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
