StephanEwen opened a new pull request #16867:
URL: https://github.com/apache/flink/pull/16867
## What is the purpose of the change
Previously, there were no log statements when source enumerators get reader
registration events, or when they receive split requests.
While some specific source implementations log this in their implementation,
for the general case, this information were missing, even though it is super
valuable when debugging and understanding the work assignment behavior.
This PR adds these log statements.
Main question to consider during the review: Would the log volume be too
high?
- For reader registration logging: Upon full failover in streaming, up to
as many log lines as parallelism on recovery when readers register again.
- For split request: For streaming, one line per initial split request,
typically few requests after that. For batch, one line per each split request
over time.
--
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]
