[
https://issues.apache.org/jira/browse/FLINK-18483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-18483:
----------------------------------
Description:
*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.
was:
*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.
> [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)
