sjwiesman opened a new pull request #273: URL: https://github.com/apache/flink-statefun/pull/273
The backlog metric sometimes reports a negative value. This is because the current count is stored in an in-memory variable, while the value used to decrement the count as the backlog clears is stored in Flink state. In the case of a job restart, the in-memory variable is reset to zero (it is a new instance) while the numbers in state are retained. Reseting the count after a restore would require iterating over all keys, so instead we simply prevent negative backlogs from being reported to not publish non-sensical values to reporters. -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
