-
Notifications
You must be signed in to change notification settings - Fork 217
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Variable drain time when shutting down via shutdown API #4966
Comments
Originally I proposed a The The |
Adds two new parameters to the shutdown API. The first is bufferReadTimeout which controls the amount of time to wait for the buffer to be empty. The second is bufferDrainTimeout which controls the overall wait time for the process worker threads to complete. To support Data Prepper durations in HTTP query parameters, I extracted the parsing logic for durations out of DataPrepperDurationDeserializer and into a new DataPrepperDurationParser class. Resolves opensearch-project#4966. Signed-off-by: David Venable <[email protected]>
…earch-project#4970) Variable drain timeouts when shutting down over HTTP shutdown. Adds two new parameters to the shutdown API. The first is bufferReadTimeout which controls the amount of time to wait for the buffer to be empty. The second is bufferDrainTimeout which controls the overall wait time for the process worker threads to complete. To support Data Prepper durations in HTTP query parameters, I extracted the parsing logic for durations out of DataPrepperDurationDeserializer and into a new DataPrepperDurationParser class. Resolves opensearch-project#4966. Signed-off-by: David Venable <[email protected]>
Is your feature request related to a problem? Please describe.
When running Data Prepper, we sometimes we want to shutdown Data Prepper faster than it is configured for.
Presently, the Data Prepper shutdown process will wait for the buffers to drain.
In some cases, we want to drain faster, say in 10 minutes.
Describe the solution you'd like
Update the shutdown API to allow for an alternate drain time.
The text was updated successfully, but these errors were encountered: