[
https://issues.apache.org/jira/browse/FLINK-31986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh resolved FLINK-31986.
-------------------------------------
Resolution: Fixed
merged commit
[{{b681cfc}}|https://github.com/apache/flink-connector-aws/commit/b681cfcd372a44a34c4e6c868cb8a69d50aac67c]
into apache:main
> Implement Integration test for FLIP-27 DataStreams API
> ------------------------------------------------------
>
> Key: FLINK-31986
> URL: https://issues.apache.org/jira/browse/FLINK-31986
> Project: Flink
> Issue Type: Sub-task
> Reporter: Hong Liang Teoh
> Assignee: Elphas Toringepi
> Priority: Major
> Labels: pull-request-available
>
> *What?*
> Implement an integration test that uses Kinesalite.
> It should spin up FLIP-27 KDS source and test:
> * Reading from single shard KDS stream
> * Reading from multiple shard KDS stream
> * Reading from resharded KDS stream
> * Failure modes (stream doesn't exist)
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
