aho135 commented on code in PR #20674: URL: https://github.com/apache/druid/pull/20674#discussion_r4391335303
########## docs/api-reference/tasks-api.md: ########## @@ -1496,6 +1496,88 @@ Host: http://ROUTER_IP:ROUTER_PORT </details> +### Handoff streaming tasks on a worker early + +Queues early handoff for every seekable-stream ingestion task running on one Middle Manager (`index_kafka`, `index_kinesis`, `index_rabbit`, and any future type that extends `SeekableStreamIndexTask`). `{host}` is the worker identity registered with the Overlord (`hostname:port`), the same value used by worker enable and disable. Compact, kill, and batch index tasks are skipped; they have no early-handoff path. To hand off a subset of task groups, use [handoff task groups for a supervisor early](supervisor-api.md#handoff-task-groups-for-a-supervisor-early). Review Comment: ```suggestion Queues early handoff for every streaming ingestion task running on one Middle Manager (`index_kafka`, `index_kinesis`, `index_rabbit`). `{host}` is the worker identity registered with the Overlord (`hostname:port`), the same value used by worker enable and disable. Compact, kill, and batch index tasks are skipped; they have no early-handoff path. To hand off a subset of task groups, use [handoff task groups for a supervisor early](supervisor-api.md#handoff-task-groups-for-a-supervisor-early). ``` I think we need not expose source code class names in the documentation here -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
