Abhi Gupta created FLINK-36523: ---------------------------------- Summary: DDB Streams connector treating LATEST as TRIM_HORIZON for some cases Key: FLINK-36523 URL: https://issues.apache.org/jira/browse/FLINK-36523 Project: Flink Issue Type: Bug Components: Connectors / DynamoDB Reporter: Abhi Gupta
For a shard lineage a->b->c->d The DDB connector starts itself as a (LATEST) -> b(TRIM_HORIZON) -> c(TRIM_HORIZON) -> d(TRIM_HORIZON) whereas it should start itself as d(LATEST) -> TRIM_HORIZON from here on. -- This message was sent by Atlassian Jira (v8.20.10#820010)