changliiu opened a new pull request, #35409: URL: https://github.com/apache/beam/pull/35409
Add new change recored actions include: 1. PartitionStartRecord -> create new partitions in the metadata tables to be scheduled. Update watermark 2. PartitionEndRecord, PartitionEventRecord -> update watermark. Note that for PartitionEndRecord, we don't explicitly finish the partition reading immediately. As the connector will notice that no further record is received after the PartitionEndRecord from the partition then it will finish the partition automatically. -- 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
