[ 
https://issues.apache.org/jira/browse/FLINK-18344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Konstantin Knauf updated FLINK-18344:
-------------------------------------
    Issue Type: Improvement  (was: Wish)

As part of https://issues.apache.org/jira/browse/FLINK-22029 the "Wish" issue 
type will be dropped. I changed this one to "Improvement" instead.

> Avoid wrong check with shardId in DynamoDB Streams
> --------------------------------------------------
>
>                 Key: FLINK-18344
>                 URL: https://issues.apache.org/jira/browse/FLINK-18344
>             Project: Flink
>          Issue Type: Improvement
>          Components: Connectors / Kinesis
>    Affects Versions: 1.10.1
>            Reporter: Javier Garcia
>            Priority: Major
>
> Change class DynamoDBStreamsShardHandle, method 
> isValidShardId to not perform check based on the assumptions of the shardId 
> format
> Using localstack as local env for testing, the shardId follow a different 
> format, valid following the AWS doc (
> [https://docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_streams_Shard.html)]
> Can you change the validation to just check the length



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to