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)