ajothomas opened a new pull request, #1637: URL: https://github.com/apache/samza/pull/1637
# Improvement: This PR is a part of the Pipeline Drain work and aims to provide a way to specify a task callback timeout to be used for pipeline drain. The standard `task.callback.timeout.ms` parameter might be too small for the drain operation to complete. Drain operation will involve clearing of intermediate state which might require a larger timeout for the task callback. We need a way to provide a configurable timeout to be used during drain operation. # Changes: - Add a new config `task.callback.drain.timeout.ms` in `TaskConfig` - Added logic to override `TaskCallbackManager`'s timeout parameter in `TaskWorker`s on drain. # Tests: - Unit test changes for `TaskConfig` -- 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
