Skip to content

Commit 7d2dd21

Browse files
pwhelanedsiper
authored andcommitted
in_calyptia_fleet: resume main collector if initial collector fails to schedule.
Signed-off-by: Phillip Whelan <[email protected]>
1 parent ed44bf5 commit 7d2dd21

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

plugins/in_calyptia_fleet/in_calyptia_fleet.c

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2103,6 +2103,8 @@ static int in_calyptia_fleet_collect_once(struct flb_input_instance *ins,
21032103

21042104
if (ctx->initial_fd == -1) {
21052105
flb_plg_error(ctx->ins, "could not initialize collector for fleet input plugin");
2106+
/* Resume main collector on retry scheduling failure */
2107+
flb_input_collector_resume(ctx->collect_fd, ins);
21062108
FLB_INPUT_RETURN(-1);
21072109
}
21082110

0 commit comments

Comments
 (0)