[
https://issues.apache.org/jira/browse/FLINK-31986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31986:
-----------------------------------
Labels: pull-request-available (was: )
> 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)
