You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@druid.apache.org by GitBox <gi...@apache.org> on 2019/03/13 00:50:10 UTC
[GitHub] [incubator-druid] justinborromeo edited a comment on issue #7217:
[PROPOSAL] API Endpoint for Supervisor Errors
justinborromeo edited a comment on issue #7217: [PROPOSAL] API Endpoint for Supervisor Errors
URL: https://github.com/apache/incubator-druid/issues/7217#issuecomment-472215067
Updated proposed states and when they change:
| State | Description | Where supervisor gets set to this state |
|--------------------------|-------------------------------------------------------------------|--------------------------------------------------------------------------------------------------------------------------------------------------|
| POSTED_NOT_RUNNING_YET | Supervisor spec has been posted but waiting for start delay | Upon SeekableStreamSupervisor instantiation |
| TRYING_TO_CONTACT_STREAM | Trying to connect to Kafka/Kinesis...hasn’t connected before | Upon the first throw of a BrokerNotFoundException (Kafka) or ResourceNotFoundException (Kinesis) if no record has been polled successfully yet. |
| LOST_CONTACT_WITH_STREAM | Trying to connect to Kafka/Kinesis...has connected before. | If a BrokerNotFoundException is thrown when polling Kafka for records or a ResourceNotFoundException is thrown when polling Kinesis for records. |
| UNABLE_TO_POLL_RECORDS | Non-connectivity related error occurring when polling for records | If any KafkaException that isn't a BrokerNotFoundException (for Kafka) or ResourceNotFoundException (for Kinesis) is thrown |
| TASKS_NOT_CREATED_YET | Supervisor started but hasn’t started indexing tasks yet | At the end of SeekableStreamSupervisor#tryInit() |
| RUNNING | Started tasks and waiting for taskDuration to elapse | At the end of SeekableStreamSupervisor#createNewTasks() |
| AWAITING_SHUTDOWN | Shutdown has been called but the supervisor hasn’t shutdown yet | At the beginning of SeekableStreamSupervisor#stop() |
| SUSPENDED | Supervisor is in a suspended state | At the beginning of SeekableStreamSupervisor#gracefulShutdownInternal() |
----------------------------------------------------------------
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:
users@infra.apache.org
With regards,
Apache Git Services
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@druid.apache.org
For additional commands, e-mail: commits-help@druid.apache.org