[jira] [Comment Edited] (FLINK-31986) Implement Integration test for FLIP-27 DataStreams API

["Hong Liang Teoh (Jira)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/FLINK-31986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883192#comment-17883192 ] 

Hong Liang Teoh edited comment on FLINK-31986 at 9/20/24 8:41 AM:
------------------------------------------------------------------

This is blocked by localstack and Kinesalite not supporting Kinesis API using StreamARN.

We would prefer to not change the way we call Kinesis API to include StreamName to fit the test limitations. Kinesis uses the StreamARN to optimize calls to the right cell to reduce latency.


was (Author: hong):
This is blocked by localstack and Kinesalite not supporting Kinesis API using StreamARN.

> 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
>            Priority: Major
>
> *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)