From e2b566e9221922ccc0398957649a8ced0cdb3fa4 Mon Sep 17 00:00:00 2001 From: Takahiro Yamashita Date: Sun, 3 Oct 2021 17:12:55 +0900 Subject: [PATCH] filter_rewrite_tag: prevent to emit original record when in_emit pauses If in_emitter pauses before original input plugin pauses, some records will emit even if keep option is disabled. Since keep property is only used when emitting is success. Signed-off-by: Takahiro Yamashita --- plugins/filter_rewrite_tag/rewrite_tag.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/plugins/filter_rewrite_tag/rewrite_tag.c b/plugins/filter_rewrite_tag/rewrite_tag.c index 28fff0ba770..de0703d38b1 100644 --- a/plugins/filter_rewrite_tag/rewrite_tag.c +++ b/plugins/filter_rewrite_tag/rewrite_tag.c @@ -398,7 +398,7 @@ static int cb_rewrite_tag_filter(const void *data, size_t bytes, * - record with new tag was emitted and the rule says it must be preserved * - record was not emitted */ - if ((ret == FLB_TRUE && keep == FLB_TRUE) || ret == FLB_FALSE) { + if (keep == FLB_TRUE) { msgpack_sbuffer_write(&mp_sbuf, (char *) data + pre, off - pre); }