cameronlee314 opened a new pull request #1561: URL: https://github.com/apache/samza/pull/1561
Issues: `TestAsyncFlatMap.testProcessingFutureCompletesAfterTaskTimeout` fails transiently. It looks like the task timeout gets triggered (which would set the error to the expected error for the test), but occasionally, before the `RunLoop` exits, the actual processing task completes, and then the final error is overridden to be `Callback complete was invoked after completion...` (since the timeout already triggered the completion of the task). Changes: Increase the delay time in the test so that the `RunLoop` has more time to exit before the actual processing task completes. Tests: `TestAsyncFlatMap.testProcessingFutureCompletesAfterTaskTimeout` passes API 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. To unsubscribe, e-mail: commits-unsubscr...@samza.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org