engine: warn when a 'retry' fails
@@ -185,6 +185,11 @@ static inline int flb_engine_manager(flb_pipefd_t fd, struct flb_config *config)
flb_buffer_chunk_pop(config->buffer_ctx, thread_id, task);
}
#endif
+ /* Notify about this failed retry */
+ flb_warn("[engine] Task cannot be retried: "
+ "task_id=%i thread_id=%i output=%s",
+ task->id, out_th->id, out_th->o_ins->name);
+
flb_output_thread_destroy_id(thread_id, task);
if (task->users == 0) {
flb_task_destroy(task);
