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)

Reply via email to