[
https://issues.apache.org/jira/browse/FLINK-18483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-18483:
----------------------------------
Description:
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
> [EFO] Test coverage improvements for existing connector
> -------------------------------------------------------
>
> 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
>
> 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
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
