Elphas Toringepi created FLINK-36427:
----------------------------------------

             Summary: Additional Integration Test cases for KDS source
                 Key: FLINK-36427
                 URL: https://issues.apache.org/jira/browse/FLINK-36427
             Project: Flink
          Issue Type: Improvement
          Components: Connectors / Kinesis
            Reporter: Elphas Toringepi


Add Integration Test cases for multiple shard and resharding
 * Reading from multiple shard KDS stream
 * Reading from resharded KDS stream
 * Mirror StopWithSavepoint test cases from old KDS source



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to