[jira] [Created] (FLINK-18344) Avoid wrong check with shardId in DynamoDB Streams

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-18344) Avoid wrong check with shardId in DynamoDB Streams

Shang Yuanchun (Jira)
Javier Garcia created FLINK-18344:
-------------------------------------

             Summary: Avoid wrong check with shardId in DynamoDB Streams
                 Key: FLINK-18344
                 URL: https://issues.apache.org/jira/browse/FLINK-18344
             Project: Flink
          Issue Type: Wish
          Components: Connectors / Kinesis
    Affects Versions: 1.10.1
            Reporter: Javier Garcia


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)