shiyiky commented on PR #3432: URL: https://github.com/apache/flink-cdc/pull/3432#issuecomment-2262208996
@ruanhang1993 Desc： 1. If the binaryLogClient does not have a registered server-id, the binaryLogClient will use the default `65535` parameter. If there is only one source in a Flink job, it will be normal. 2. If multiple sources register binaryLogClients using the default `65535` in a Flink job, registration may fail because one of the sources is searching for the timestamp of the binlog file and has not yet released the client registered using `65535` as the `server-id`. 3. If registration fails. BlockingQueue will always be empty and waiting without doing nothing. Changes： When registering the binaryLogClient to search timestamp , use the `server-id` unique to each source for registration. -- 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]
