cameronlee314 opened a new pull request #1382: URL: https://github.com/apache/samza/pull/1382
Symptom: `TestKafkaCheckpointManager.testWriteCheckpointShouldRecreateSystemProducerOnFailure` was not enabled. It also did not pass when it was enabled. It doesn't seem like this was a disabled flaky test; just seems like the author forgot to enable it. Cause: 1. Missing the `@Test` annotation. 2. Retry timeout was set too low, so the test never had the chance to recreate the system producer. Tests: `./gradlew :samza-kafka:test --tests TestKafkaCheckpointManager` API/Usage changes: N/A ---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: [email protected]
