task: on retries, put chunk down
@@ -164,6 +164,14 @@ struct flb_task_retry *flb_task_retry_create(struct flb_task *task,
*/
flb_input_chunk_set_up_down(task->ic);
+ /*
+ * Besides limits adjusted above, a retry that's going to only one place
+ * must be down.
+ */
+ if (mk_list_size(&task->routes) == 1) {
+ flb_input_chunk_down(task->ic);
+ }
+
return retry;
}
