goutamadwant commented on PR #11512: URL: https://github.com/apache/seatunnel/pull/11512#issuecomment-5082253644
@nzw921rx @DanielLeens I updated the latest head based on the ownership and duplication feedback - reader and enumerator reports now share CdcProgressProvider CdcProgressReport and one tagged envelope storage and serialization path - reader and enumerator payloads remain separate - enumerator progress now reports snapshot assignment state only and no longer reports CATCH_UP - enumerator progress is collected directly on the coordinator when the enumerator is local - Serializable is removed from the connector facing progress model and transport still uses the explicit codec I also added coverage for assignment states owner and payload validation ordering and wire serialization. The focused API connector base and engine progress tests pass locally Could you please check if this now matches the STIP ownership and collection model -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
