diff --git a/plugins/out_forward/forward.c b/plugins/out_forward/forward.c index 82e83b2d305..ea7904691c9 100644 --- a/plugins/out_forward/forward.c +++ b/plugins/out_forward/forward.c @@ -1574,9 +1574,7 @@ static void cb_forward_flush(struct flb_event_chunk *event_chunk, if (!u_conn) { flb_plg_error(ctx->ins, "no upstream connections available"); msgpack_sbuffer_destroy(&mp_sbuf); - if (fc->time_as_integer == FLB_TRUE) { - flb_free(out_buf); - } + flb_free(out_buf); flb_free(flush_ctx); FLB_OUTPUT_RETURN(FLB_RETRY); } @@ -1590,9 +1588,7 @@ static void cb_forward_flush(struct flb_event_chunk *event_chunk, flb_plg_error(ctx->ins, "no unix socket connection available"); msgpack_sbuffer_destroy(&mp_sbuf); - if (fc->time_as_integer == FLB_TRUE) { - flb_free(out_buf); - } + flb_free(out_buf); flb_free(flush_ctx); FLB_OUTPUT_RETURN(FLB_RETRY); } @@ -1622,9 +1618,7 @@ static void cb_forward_flush(struct flb_event_chunk *event_chunk, } msgpack_sbuffer_destroy(&mp_sbuf); - if (fc->time_as_integer == FLB_TRUE) { - flb_free(out_buf); - } + flb_free(out_buf); flb_free(flush_ctx); FLB_OUTPUT_RETURN(FLB_RETRY); }