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)