changliiu commented on PR #34967: URL: https://github.com/apache/beam/pull/34967#issuecomment-2977405659
> Just so I understand things correctly: > > 1. The change stream v2 partition token does not have an explicit end timestamp > 2. Users however are required to provide an end timestamp to their change stream V2 queries within 30 minutes in the future > 3. We chose 2 minutes, since it is relatively small and > the Dataflow 5s checkpointing. > > Was wondering if you could confirm? 1. V2 change stream required end_timestamp, and it's cannot be omitted. 2. However, connector end_timestamp can be skipped. If so, the connector needs to run forever. 3. Yes. Please let me know if more details/explanation is needed. Thanks! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: github-unsubscr...@beam.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
