Ironankit525 opened a new pull request, #8414: URL: https://github.com/apache/storm/pull/8414
Addresses Issue #3 from static analysis. When verifying if a Trident batch finish condition is met, the executor checks if the number of received tuples matches the number of actual tuple counts. If there is a mismatch, the executor invokes failBatch(tracked) and rejects the tuple, but without any logging indicating the mismatch. This PR adds an SLF4J `LOG.warn` explaining the mismatch so that operators can correctly diagnose data loss or malformed batches. -- 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]
