Skip to content

upstream: prioritize the reuse of connections instead of establishing new ones #10491

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom
Open
wants to merge 1 commit into
base: master
Choose a base branch
from
Open

upstream: prioritize the reuse of connections instead of establishing new ones #10491

wants to merge 1 commit into from

Conversation

lecaros
Copy link
Contributor

@lecaros lecaros commented Jun 18, 2025 •
edited
Loading

Currently, we're prioritizing the creation of new connections if there's no limit on them or if we are within the limits.
This commit prioritizes the reuse of connections and only creates one if there are no available ones and we're within the limits (if any).
This should address #10342
This also fixes a regression introduced in #10423 where we were not reusing connections in the av_queue.

Enter [N/A] in the box, if an item is not applicable to your change.

Testing
Before we can approve your change; please submit the following in a comment:

  • Example configuration file for the change
pipeline:
  inputs:
    - name: dummy
      tag: dummy
    - name: forward
      port: 8888
      tag: fwd
  outputs:
    - name: stdout
      match: 'fwd'
    - name: forward
      match: dummy
      host: localhost
      port: 8888
service:
  log_level: debug
  • Debug log output from testing the change
Debug output 
valgrind $FBIT_HOME/bin/fluent-bit -c fluent-bit.yml
==3455327== Memcheck, a memory error detector
==3455327== Copyright (C) 2002-2017, and GNU GPL'd, by Julian Seward et al.
==3455327== Using Valgrind-3.18.1 and LibVEX; rerun with -h for copyright info
==3455327== Command: /home/lecaros/workspaces/fluent/fluent-bit/build/bin/fluent-bit -c fluent-bit.yml
==3455327== 
Fluent Bit v4.0.4
* Copyright (C) 2015-2025 The Fluent Bit Authors
* Fluent Bit is a CNCF sub-project under the umbrella of Fluentd
* https://fluentbit.io

______ _                  _    ______ _ _             ___  _____ 
|  ___| |                | |   | ___ (_) |           /   ||  _  |
| |_  | |_   _  ___ _ __ | |_  | |_/ /_| |_  __   __/ /| || |/' |
|  _| | | | | |/ _ \ '_ \| __| | ___ \ | __| \ \ / / /_| ||  /| |
| |   | | |_| |  __/ | | | |_  | |_/ / | |_   \ V /\___  |\ |_/ /
\_|   |_|\__,_|\___|_| |_|\__| \____/|_|\__|   \_/     |_(_)___/ 


[2025/06/24 17:51:27] [ info] Configuration:
[2025/06/24 17:51:27] [ info]  flush time     | 1.000000 seconds
[2025/06/24 17:51:27] [ info]  grace          | 5 seconds
[2025/06/24 17:51:27] [ info]  daemon         | 0
[2025/06/24 17:51:27] [ info] ___________
[2025/06/24 17:51:27] [ info]  inputs:
[2025/06/24 17:51:27] [ info]      dummy
[2025/06/24 17:51:27] [ info]      forward
[2025/06/24 17:51:27] [ info] ___________
[2025/06/24 17:51:27] [ info]  filters:
[2025/06/24 17:51:27] [ info] ___________
[2025/06/24 17:51:27] [ info]  outputs:
[2025/06/24 17:51:27] [ info]      stdout.0
[2025/06/24 17:51:27] [ info]      forward.1
[2025/06/24 17:51:27] [ info] ___________
[2025/06/24 17:51:27] [ info]  collectors:
[2025/06/24 17:51:27] [ info] [fluent bit] version=4.0.4, commit=af3d1b9e96, pid=3455327
[2025/06/24 17:51:27] [debug] [engine] coroutine stack size: 24576 bytes (24.0K)
[2025/06/24 17:51:27] [ info] [storage] ver=1.1.6, type=memory, sync=normal, checksum=off, max_chunks_up=128
[2025/06/24 17:51:27] [ info] [simd    ] disabled
[2025/06/24 17:51:27] [ info] [cmetrics] version=1.0.3
[2025/06/24 17:51:27] [ info] [ctraces ] version=0.6.6
[2025/06/24 17:51:27] [ info] [input:dummy:dummy.0] initializing
[2025/06/24 17:51:27] [ info] [input:dummy:dummy.0] storage_strategy='memory' (memory only)
[2025/06/24 17:51:27] [debug] [dummy:dummy.0] created event channels: read=25 write=26
[2025/06/24 17:51:27] [ info] [input:forward:forward.1] initializing
[2025/06/24 17:51:27] [ info] [output:forward:forward.1] worker #0 started
[2025/06/24 17:51:27] [ info] [output:stdout:stdout.0] worker #0 started
[2025/06/24 17:51:27] [ info] [output:forward:forward.1] worker #1 started
[2025/06/24 17:51:27] [ info] [input:forward:forward.1] storage_strategy='memory' (memory only)
[2025/06/24 17:51:27] [debug] [forward:forward.1] created event channels: read=27 write=28
[2025/06/24 17:51:27] [debug] [in_fw] Listen='0.0.0.0' TCP_Port=8888
[2025/06/24 17:51:27] [debug] [downstream] listening on 0.0.0.0:8888
[2025/06/24 17:51:27] [ info] [input:forward:forward.1] listening on 0.0.0.0:8888
[2025/06/24 17:51:27] [debug] [stdout:stdout.0] created event channels: read=30 write=31
[2025/06/24 17:51:27] [debug] [forward:forward.1] created event channels: read=39 write=40
[2025/06/24 17:51:27] [debug] [router] match rule dummy.0:forward.1
[2025/06/24 17:51:27] [debug] [router] match rule forward.1:stdout.0
[2025/06/24 17:51:27] [ info] [sp] stream processor started
[2025/06/24 17:51:27] [ info] [engine] Shutdown Grace Period=5, Shutdown Input Grace Period=2
[2025/06/24 17:51:29] [debug] [task] created task=0x6180190 id=0 OK
[2025/06/24 17:51:29] [debug] [output:forward:forward.1] task_id=0 assigned to thread #0
[2025/06/24 17:51:29] [debug] [output:forward:forward.1] request 36 bytes to flush
[2025/06/24 17:51:30] [debug] [upstream] KA connection #77 to localhost:8888 is connected
[2025/06/24 17:51:30] [debug] [upstream] KA connection #77 to localhost:8888 is now available
[2025/06/24 17:51:30] [debug] [out flush] cb_destroy coro_id=0
[2025/06/24 17:51:30] [debug] [task] destroy task=0x6180190 (task_id=0)
[0] fwd: [[1750801888.717285027, {}], {"message"=>"dummy"}]
[2025/06/24 17:51:30] [debug] [task] created task=0x633ce50 id=0 OK
[2025/06/24 17:51:30] [debug] [output:forward:forward.1] task_id=0 assigned to thread #1
[2025/06/24 17:51:30] [debug] [output:forward:forward.1] request 36 bytes to flush
[2025/06/24 17:51:30] [debug] [out flush] cb_destroy coro_id=0
[2025/06/24 17:51:30] [debug] [task] created task=0x633d060 id=1 OK
[2025/06/24 17:51:30] [debug] [upstream] KA connection #79 to localhost:8888 is connected
[2025/06/24 17:51:30] [debug] [output:stdout:stdout.0] task_id=1 assigned to thread #0
[2025/06/24 17:51:30] [debug] [upstream] KA connection #79 to localhost:8888 is now available
[2025/06/24 17:51:30] [debug] [task] destroy task=0x633d060 (task_id=1)
[2025/06/24 17:51:30] [debug] [out flush] cb_destroy coro_id=0
[2025/06/24 17:51:30] [debug] [task] destroy task=0x633ce50 (task_id=0)
[2025/06/24 17:51:31] [debug] [task] created task=0x63fbb50 id=0 OK
[2025/06/24 17:51:31] [debug] [output:forward:forward.1] task_id=0 assigned to thread #0
[2025/06/24 17:51:31] [debug] [task] created task=0x63fbc90 id=1 OK
[2025/06/24 17:51:31] [debug] [output:stdout:stdout.0] task_id=1 assigned to thread #0
[0] fwd: [[1750801889.733477064, {}], {"message"=>"dummy"}]
[2025/06/24 17:51:31] [debug] [output:forward:forward.1] request 36 bytes to flush
[2025/06/24 17:51:31] [debug] [upstream] KA connection #77 to localhost:8888 has been assigned (recycled)
[2025/06/24 17:51:31] [debug] [out flush] cb_destroy coro_id=1
[2025/06/24 17:51:31] [debug] [task] destroy task=0x63fbc90 (task_id=1)
[2025/06/24 17:51:31] [debug] [upstream] KA connection #77 to localhost:8888 is now available
[2025/06/24 17:51:31] [debug] [out flush] cb_destroy coro_id=1
[2025/06/24 17:51:31] [debug] [task] destroy task=0x63fbb50 (task_id=0)
[2025/06/24 17:51:32] [debug] [task] created task=0x6421570 id=0 OK
[2025/06/24 17:51:32] [debug] [output:forward:forward.1] task_id=0 assigned to thread #1
[0] fwd: [[1750801890.696708343, {}], {"message"=>"dummy"}]
[2025/06/24 17:51:32] [debug] [output:forward:forward.1] request 36 bytes to flush
[2025/06/24 17:51:32] [debug] [task] created task=0x6421780 id=1 OK
[2025/06/24 17:51:32] [debug] [upstream] KA connection #79 to localhost:8888 has been assigned (recycled)
[2025/06/24 17:51:32] [debug] [out flush] cb_destroy coro_id=2
[2025/06/24 17:51:32] [debug] [output:stdout:stdout.0] task_id=1 assigned to thread #0
[2025/06/24 17:51:32] [debug] [upstream] KA connection #79 to localhost:8888 is now available
[2025/06/24 17:51:32] [debug] [task] destroy task=0x6421570 (task_id=0)
[2025/06/24 17:51:32] [debug] [out flush] cb_destroy coro_id=1
[2025/06/24 17:51:32] [debug] [task] destroy task=0x6421780 (task_id=1)
[2025/06/24 17:51:33] [debug] [task] created task=0x8e69020 id=0 OK
[2025/06/24 17:51:33] [debug] [output:forward:forward.1] task_id=0 assigned to thread #0
[0] fwd: [[1750801891.699510656, {}], {"message"=>"dummy"}]
[2025/06/24 17:51:33] [debug] [output:forward:forward.1] request 36 bytes to flush
[2025/06/24 17:51:33] [debug] [task] created task=0x8e69230 id=1 OK
[2025/06/24 17:51:33] [debug] [upstream] KA connection #77 to localhost:8888 has been assigned (recycled)
[2025/06/24 17:51:33] [debug] [out flush] cb_destroy coro_id=3
[2025/06/24 17:51:33] [debug] [output:stdout:stdout.0] task_id=1 assigned to thread #0
[2025/06/24 17:51:33] [debug] [upstream] KA connection #77 to localhost:8888 is now available
[2025/06/24 17:51:33] [debug] [task] destroy task=0x8e69230 (task_id=1)
[2025/06/24 17:51:33] [debug] [out flush] cb_destroy coro_id=2
[2025/06/24 17:51:33] [debug] [task] destroy task=0x8e69020 (task_id=0)
[2025/06/24 17:51:34] [debug] [task] created task=0x8f1f530 id=0 OK
[0] fwd: [[1750801892.739171101, {}], {"message"=>"dummy"}]
[2025/06/24 17:51:34] [debug] [output:forward:forward.1] task_id=0 assigned to thread #1
[2025/06/24 17:51:34] [debug] [output:forward:forward.1] request 36 bytes to flush
[2025/06/24 17:51:34] [debug] [task] created task=0x8f1f740 id=1 OK
[2025/06/24 17:51:34] [debug] [upstream] KA connection #79 to localhost:8888 has been assigned (recycled)
[2025/06/24 17:51:34] [debug] [out flush] cb_destroy coro_id=4
[2025/06/24 17:51:34] [debug] [output:stdout:stdout.0] task_id=1 assigned to thread #0
[2025/06/24 17:51:34] [debug] [upstream] KA connection #79 to localhost:8888 is now available
[2025/06/24 17:51:34] [debug] [task] destroy task=0x8f1f740 (task_id=1)
[2025/06/24 17:51:34] [debug] [out flush] cb_destroy coro_id=2
[2025/06/24 17:51:34] [debug] [task] destroy task=0x8f1f530 (task_id=0)
[0] fwd: [[1750801893.698098107, {}], {"message"=>"dummy"}]
[2025/06/24 17:51:35] [debug] [task] created task=0x8fd2700 id=0 OK
[2025/06/24 17:51:35] [debug] [output:forward:forward.1] task_id=0 assigned to thread #0
[2025/06/24 17:51:35] [debug] [task] created task=0x8fd2910 id=1 OK
[2025/06/24 17:51:35] [debug] [output:stdout:stdout.0] task_id=1 assigned to thread #0
[2025/06/24 17:51:35] [debug] [output:forward:forward.1] request 36 bytes to flush
[2025/06/24 17:51:35] [debug] [task] destroy task=0x8fd2910 (task_id=1)
[2025/06/24 17:51:35] [debug] [upstream] KA connection #77 to localhost:8888 has been assigned (recycled)
[2025/06/24 17:51:35] [debug] [out flush] cb_destroy coro_id=5
[2025/06/24 17:51:35] [debug] [task] destroy task=0x8fd2700 (task_id=0)
[2025/06/24 17:51:35] [debug] [upstream] KA connection #77 to localhost:8888 is now available
[2025/06/24 17:51:35] [debug] [out flush] cb_destroy coro_id=3
[2025/06/24 17:51:36] [debug] [task] created task=0x9088c50 id=0 OK
[2025/06/24 17:51:36] [debug] [output:forward:forward.1] task_id=0 assigned to thread #1
[0] fwd: [[1750801894.695393493, {}], {"message"=>"dummy"}]
[2025/06/24 17:51:36] [debug] [output:forward:forward.1] request 36 bytes to flush
[2025/06/24 17:51:36] [debug] [task] created task=0x9088e60 id=1 OK
[2025/06/24 17:51:36] [debug] [upstream] KA connection #79 to localhost:8888 has been assigned (recycled)
[2025/06/24 17:51:36] [debug] [out flush] cb_destroy coro_id=6
[2025/06/24 17:51:36] [debug] [output:stdout:stdout.0] task_id=1 assigned to thread #0
[2025/06/24 17:51:36] [debug] [upstream] KA connection #79 to localhost:8888 is now available
[2025/06/24 17:51:36] [debug] [task] destroy task=0x9088e60 (task_id=1)
[2025/06/24 17:51:36] [debug] [out flush] cb_destroy coro_id=3
[2025/06/24 17:51:36] [debug] [task] destroy task=0x9088c50 (task_id=0)
[2025/06/24 17:51:37] [debug] [task] created task=0x91410b0 id=0 OK
[2025/06/24 17:51:37] [debug] [output:forward:forward.1] task_id=0 assigned to thread #0
[0] fwd: [[1750801895.694262815, {}], {"message"=>"dummy"}]
[2025/06/24 17:51:37] [debug] [output:forward:forward.1] request 36 bytes to flush
[2025/06/24 17:51:37] [debug] [task] created task=0x91412c0 id=1 OK
[2025/06/24 17:51:37] [debug] [upstream] KA connection #77 to localhost:8888 has been assigned (recycled)
[2025/06/24 17:51:37] [debug] [out flush] cb_destroy coro_id=7
[2025/06/24 17:51:37] [debug] [output:stdout:stdout.0] task_id=1 assigned to thread #0
[2025/06/24 17:51:37] [debug] [task] destroy task=0x91412c0 (task_id=1)
[2025/06/24 17:51:37] [debug] [upstream] KA connection #77 to localhost:8888 is now available
[2025/06/24 17:51:37] [debug] [task] destroy task=0x91410b0 (task_id=0)
[2025/06/24 17:51:37] [debug] [out flush] cb_destroy coro_id=4
[0] fwd: [[1750801896.702237904, {}], {"message"=>"dummy"}]
[2025/06/24 17:51:38] [debug] [task] created task=0x91f75c0 id=0 OK
[2025/06/24 17:51:38] [debug] [output:forward:forward.1] task_id=0 assigned to thread #1
[2025/06/24 17:51:38] [debug] [out flush] cb_destroy coro_id=8
[2025/06/24 17:51:38] [debug] [task] created task=0x91f77d0 id=1 OK
[2025/06/24 17:51:38] [debug] [output:forward:forward.1] request 36 bytes to flush
[2025/06/24 17:51:38] [debug] [output:stdout:stdout.0] task_id=1 assigned to thread #0
[2025/06/24 17:51:38] [debug] [upstream] KA connection #79 to localhost:8888 has been assigned (recycled)
[2025/06/24 17:51:38] [debug] [task] destroy task=0x91f77d0 (task_id=1)
[2025/06/24 17:51:38] [debug] [upstream] KA connection #79 to localhost:8888 is now available
[2025/06/24 17:51:38] [debug] [task] destroy task=0x91f75c0 (task_id=0)
[2025/06/24 17:51:38] [debug] [out flush] cb_destroy coro_id=4
[2025/06/24 17:51:39] [debug] [task] created task=0x92aa880 id=0 OK
[2025/06/24 17:51:39] [debug] [output:forward:forward.1] task_id=0 assigned to thread #0
[0] fwd: [[1750801897.700112925, {}], {"message"=>"dummy"}]
[2025/06/24 17:51:39] [debug] [output:forward:forward.1] request 36 bytes to flush
[2025/06/24 17:51:39] [debug] [task] created task=0x92aaa90 id=1 OK
[2025/06/24 17:51:39] [debug] [upstream] KA connection #77 to localhost:8888 has been assigned (recycled)
[2025/06/24 17:51:39] [debug] [out flush] cb_destroy coro_id=9
[2025/06/24 17:51:39] [debug] [output:stdout:stdout.0] task_id=1 assigned to thread #0
[2025/06/24 17:51:39] [debug] [upstream] KA connection #77 to localhost:8888 is now available
[2025/06/24 17:51:39] [debug] [task] destroy task=0x92aaa90 (task_id=1)
[2025/06/24 17:51:39] [debug] [out flush] cb_destroy coro_id=5
[2025/06/24 17:51:39] [debug] [task] destroy task=0x92aa880 (task_id=0)
[2025/06/24 17:51:40] [debug] [task] created task=0x935da50 id=0 OK
[2025/06/24 17:51:40] [debug] [output:forward:forward.1] task_id=0 assigned to thread #1
[2025/06/24 17:51:40] [debug] [task] created task=0x935dc60 id=1 OK
[2025/06/24 17:51:40] [debug] [output:stdout:stdout.0] task_id=1 assigned to thread #0
[2025/06/24 17:51:40] [debug] [output:forward:forward.1] request 36 bytes to flush
[0] fwd: [[1750801898.697445422, {}], {"message"=>"dummy"}]
[2025/06/24 17:51:40] [debug] [upstream] KA connection #79 to localhost:8888 has been assigned (recycled)
[2025/06/24 17:51:40] [debug] [out flush] cb_destroy coro_id=10
[2025/06/24 17:51:40] [debug] [upstream] KA connection #79 to localhost:8888 is now available
[2025/06/24 17:51:40] [debug] [task] destroy task=0x935dc60 (task_id=1)
[2025/06/24 17:51:40] [debug] [out flush] cb_destroy coro_id=5
[2025/06/24 17:51:40] [debug] [task] destroy task=0x935da50 (task_id=0)
[2025/06/24 17:51:41] [debug] [task] created task=0x9413e70 id=0 OK
[2025/06/24 17:51:41] [debug] [output:forward:forward.1] task_id=0 assigned to thread #0
[0] fwd: [[1750801899.699193533, {}], {"message"=>"dummy"}]
[2025/06/24 17:51:41] [debug] [output:forward:forward.1] request 36 bytes to flush
[2025/06/24 17:51:41] [debug] [task] created task=0x942a8c0 id=1 OK
[2025/06/24 17:51:41] [debug] [upstream] KA connection #77 to localhost:8888 has been assigned (recycled)
[2025/06/24 17:51:41] [debug] [out flush] cb_destroy coro_id=11
[2025/06/24 17:51:41] [debug] [output:stdout:stdout.0] task_id=1 assigned to thread #0
[2025/06/24 17:51:41] [debug] [upstream] KA connection #77 to localhost:8888 is now available
[2025/06/24 17:51:41] [debug] [task] destroy task=0x9413e70 (task_id=0)
[2025/06/24 17:51:41] [debug] [out flush] cb_destroy coro_id=6
[2025/06/24 17:51:41] [debug] [task] destroy task=0x942a8c0 (task_id=1)
[0] fwd: [[1750801900.695594000, {}], {"message"=>"dummy"}]
[2025/06/24 17:51:42] [debug] [task] created task=0x943aca0 id=0 OK
[2025/06/24 17:51:42] [debug] [output:forward:forward.1] task_id=0 assigned to thread #1
[2025/06/24 17:51:42] [debug] [output:forward:forward.1] request 36 bytes to flush
[2025/06/24 17:51:42] [debug] [out flush] cb_destroy coro_id=12
[2025/06/24 17:51:42] [debug] [task] created task=0x943aeb0 id=1 OK
[2025/06/24 17:51:42] [debug] [upstream] KA connection #79 to localhost:8888 has been assigned (recycled)
[2025/06/24 17:51:42] [debug] [output:stdout:stdout.0] task_id=1 assigned to thread #0
[2025/06/24 17:51:42] [debug] [upstream] KA connection #79 to localhost:8888 is now available
[2025/06/24 17:51:42] [debug] [task] destroy task=0x943aeb0 (task_id=1)
[2025/06/24 17:51:42] [debug] [out flush] cb_destroy coro_id=6
[2025/06/24 17:51:42] [debug] [task] destroy task=0x943aca0 (task_id=0)
[2025/06/24 17:51:43] [debug] [task] created task=0x957c280 id=0 OK
[2025/06/24 17:51:43] [debug] [output:forward:forward.1] task_id=0 assigned to thread #0
[2025/06/24 17:51:43] [debug] [task] created task=0x957c490 id=1 OK
[0] fwd: [[1750801901.698105469, {}], {"message"=>"dummy"}]
[2025/06/24 17:51:43] [debug] [output:forward:forward.1] request 36 bytes to flush
[2025/06/24 17:51:43] [debug] [output:stdout:stdout.0] task_id=1 assigned to thread #0
[2025/06/24 17:51:43] [debug] [upstream] KA connection #77 to localhost:8888 has been assigned (recycled)
[2025/06/24 17:51:43] [debug] [task] destroy task=0x957c280 (task_id=0)
[2025/06/24 17:51:43] [debug] [upstream] KA connection #77 to localhost:8888 is now available
[2025/06/24 17:51:43] [debug] [out flush] cb_destroy coro_id=13
[2025/06/24 17:51:43] [debug] [task] destroy task=0x957c490 (task_id=1)
[2025/06/24 17:51:43] [debug] [out flush] cb_destroy coro_id=7
^C[2025/06/24 17:51:44] [engine] caught signal (SIGINT)
[2025/06/24 17:51:44] [debug] [task] created task=0x96326f0 id=0 OK
[2025/06/24 17:51:44] [debug] [output:forward:forward.1] task_id=0 assigned to thread #1
[2025/06/24 17:51:44] [debug] [output:forward:forward.1] request 36 bytes to flush
[2025/06/24 17:51:44] [debug] [task] created task=0x9638ca0 id=1 OK
[2025/06/24 17:51:44] [debug] [upstream] KA connection #79 to localhost:8888 has been assigned (recycled)
[2025/06/24 17:51:44] [debug] [output:stdout:stdout.0] task_id=1 assigned to thread #0
[2025/06/24 17:51:44] [debug] [upstream] KA connection #79 to localhost:8888 is now available
[2025/06/24 17:51:44] [debug] [out flush] cb_destroy coro_id=7
[0] fwd: [[1750801902.699511537, {}], {"message"=>"dummy"}]
==3455327== Thread 2 flb-pipeline:
==3455327== Conditional jump or move depends on uninitialised value(s)
==3455327==    at 0x52CFE85: __vfprintf_internal (vfprintf-internal.c:1516)
==3455327==    by 0x52E2499: __vsnprintf_internal (vsnprintf.c:114)
==3455327==    by 0x24640D: flb_log_construct (flb_log.c:747)
==3455327==    by 0x2466E7: flb_log_print (flb_log.c:810)
==3455327==    by 0x2BAE69: flb_engine_reschedule_retries (flb_engine.c:136)
==3455327==    by 0x2BD0E2: flb_engine_start (flb_engine.c:1005)
==3455327==    by 0x240BDE: flb_lib_worker (flb_lib.c:835)
==3455327==    by 0x52EEAC2: start_thread (pthread_create.c:442)
==3455327==    by 0x537FA03: clone (clone.S:100)
==3455327== 
==3455327== Use of uninitialised value of size 8
==3455327==    at 0x52B428A: _itoa_word (_itoa.c:178)
==3455327==    by 0x52CFABD: __vfprintf_internal (vfprintf-internal.c:1516)
==3455327==    by 0x52E2499: __vsnprintf_internal (vsnprintf.c:114)
==3455327==    by 0x24640D: flb_log_construct (flb_log.c:747)
==3455327==    by 0x2466E7: flb_log_print (flb_log.c:810)
==3455327==    by 0x2BAE69: flb_engine_reschedule_retries (flb_engine.c:136)
==3455327==    by 0x2BD0E2: flb_engine_start (flb_engine.c:1005)
==3455327==    by 0x240BDE: flb_lib_worker (flb_lib.c:835)
==3455327==    by 0x52EEAC2: start_thread (pthread_create.c:442)
==3455327==    by 0x537FA03: clone (clone.S:100)
==3455327== 
==3455327== Conditional jump or move depends on uninitialised value(s)
==3455327==    at 0x52B429C: _itoa_word (_itoa.c:178)
==3455327==    by 0x52CFABD: __vfprintf_internal (vfprintf-internal.c:1516)
==3455327==    by 0x52E2499: __vsnprintf_internal (vsnprintf.c:114)
==3455327==    by 0x24640D: flb_log_construct (flb_log.c:747)
==3455327==    by 0x2466E7: flb_log_print (flb_log.c:810)
==3455327==    by 0x2BAE69: flb_engine_reschedule_retries (flb_engine.c:136)
==3455327==    by 0x2BD0E2: flb_engine_start (flb_engine.c:1005)
==3455327==    by 0x240BDE: flb_lib_worker (flb_lib.c:835)
==3455327==    by 0x52EEAC2: start_thread (pthread_create.c:442)
==3455327==    by 0x537FA03: clone (clone.S:100)
==3455327== 
==3455327== Conditional jump or move depends on uninitialised value(s)
==3455327==    at 0x52D05C3: __vfprintf_internal (vfprintf-internal.c:1516)
==3455327==    by 0x52E2499: __vsnprintf_internal (vsnprintf.c:114)
==3455327==    by 0x24640D: flb_log_construct (flb_log.c:747)
==3455327==    by 0x2466E7: flb_log_print (flb_log.c:810)
==3455327==    by 0x2BAE69: flb_engine_reschedule_retries (flb_engine.c:136)
==3455327==    by 0x2BD0E2: flb_engine_start (flb_engine.c:1005)
==3455327==    by 0x240BDE: flb_lib_worker (flb_lib.c:835)
==3455327==    by 0x52EEAC2: start_thread (pthread_create.c:442)
==3455327==    by 0x537FA03: clone (clone.S:100)
==3455327== 
==3455327== Conditional jump or move depends on uninitialised value(s)
==3455327==    at 0x52CFC05: __vfprintf_internal (vfprintf-internal.c:1516)
==3455327==    by 0x52E2499: __vsnprintf_internal (vsnprintf.c:114)
==3455327==    by 0x24640D: flb_log_construct (flb_log.c:747)
==3455327==    by 0x2466E7: flb_log_print (flb_log.c:810)
==3455327==    by 0x2BAE69: flb_engine_reschedule_retries (flb_engine.c:136)
==3455327==    by 0x2BD0E2: flb_engine_start (flb_engine.c:1005)
==3455327==    by 0x240BDE: flb_lib_worker (flb_lib.c:835)
==3455327==    by 0x52EEAC2: start_thread (pthread_create.c:442)
==3455327==    by 0x537FA03: clone (clone.S:100)
==3455327== 
[2025/06/24 17:51:44] [ warn] [engine] service will shutdown in max 5 seconds
[2025/06/24 17:51:44] [debug] [engine] retry=0x6c2d130 for task 0 already scheduled to run, not re-scheduling it.
[2025/06/24 17:51:44] [debug] [upstream] KA connection #79 to localhost:8888 has been disconnected by the remote service
[2025/06/24 17:51:44] [debug] [engine] retry=0x6c2d130 for task 1 already scheduled to run, not re-scheduling it.
[2025/06/24 17:51:44] [ info] [input] pausing dummy.0
[2025/06/24 17:51:44] [debug] [upstream] KA connection #77 to localhost:8888 has been disconnected by the remote service
[2025/06/24 17:51:44] [debug] [out flush] cb_destroy coro_id=14
[2025/06/24 17:51:44] [ info] [input] pausing forward.1
[2025/06/24 17:51:44] [debug] [task] destroy task=0x96326f0 (task_id=0)
[2025/06/24 17:51:44] [debug] [task] destroy task=0x9638ca0 (task_id=1)
[2025/06/24 17:51:44] [ info] [engine] service has stopped (0 pending tasks)
[2025/06/24 17:51:44] [ info] [input] pausing dummy.0
[2025/06/24 17:51:44] [ info] [input] pausing forward.1
[2025/06/24 17:51:44] [ info] [output:stdout:stdout.0] thread worker #0 stopping...
[2025/06/24 17:51:44] [ info] [output:stdout:stdout.0] thread worker #0 stopped
[2025/06/24 17:51:44] [ info] [output:forward:forward.1] thread worker #0 stopping...
[2025/06/24 17:51:44] [ info] [output:forward:forward.1] thread worker #0 stopped
[2025/06/24 17:51:44] [ info] [output:forward:forward.1] thread worker #1 stopping...
[2025/06/24 17:51:44] [ info] [output:forward:forward.1] thread worker #1 stopped
==3455327== 
==3455327== HEAP SUMMARY:
==3455327==     in use at exit: 0 bytes in 0 blocks
==3455327==   total heap usage: 5,768 allocs, 5,768 frees, 14,393,982 bytes allocated
==3455327== 
==3455327== All heap blocks were freed -- no leaks are possible
==3455327== 
==3455327== Use --track-origins=yes to see where uninitialised values come from
==3455327== For lists of detected and suppressed errors, rerun with: -s
==3455327== ERROR SUMMARY: 34 errors from 5 contexts (suppressed: 0 from 0)
  • Attached Valgrind output that shows no leaks or memory corruption was found
Valgrind output 
valgrind $FBIT_HOME/bin/fluent-bit -c fluent-bit.yml
==3455327== Memcheck, a memory error detector
==3455327== Copyright (C) 2002-2017, and GNU GPL'd, by Julian Seward et al.
==3455327== Using Valgrind-3.18.1 and LibVEX; rerun with -h for copyright info
==3455327== Command: /home/lecaros/workspaces/fluent/fluent-bit/build/bin/fluent-bit -c fluent-bit.yml
==3455327== 
Fluent Bit v4.0.4
* Copyright (C) 2015-2025 The Fluent Bit Authors
* Fluent Bit is a CNCF sub-project under the umbrella of Fluentd
* https://fluentbit.io

______ _                  _    ______ _ _             ___  _____ 
|  ___| |                | |   | ___ (_) |           /   ||  _  |
| |_  | |_   _  ___ _ __ | |_  | |_/ /_| |_  __   __/ /| || |/' |
|  _| | | | | |/ _ \ '_ \| __| | ___ \ | __| \ \ / / /_| ||  /| |
| |   | | |_| |  __/ | | | |_  | |_/ / | |_   \ V /\___  |\ |_/ /
\_|   |_|\__,_|\___|_| |_|\__| \____/|_|\__|   \_/     |_(_)___/ 


[2025/06/24 17:51:27] [ info] Configuration:
[2025/06/24 17:51:27] [ info]  flush time     | 1.000000 seconds
[2025/06/24 17:51:27] [ info]  grace          | 5 seconds
[2025/06/24 17:51:27] [ info]  daemon         | 0
[2025/06/24 17:51:27] [ info] ___________
[2025/06/24 17:51:27] [ info]  inputs:
[2025/06/24 17:51:27] [ info]      dummy
[2025/06/24 17:51:27] [ info]      forward
[2025/06/24 17:51:27] [ info] ___________
[2025/06/24 17:51:27] [ info]  filters:
[2025/06/24 17:51:27] [ info] ___________
[2025/06/24 17:51:27] [ info]  outputs:
[2025/06/24 17:51:27] [ info]      stdout.0
[2025/06/24 17:51:27] [ info]      forward.1
[2025/06/24 17:51:27] [ info] ___________
[2025/06/24 17:51:27] [ info]  collectors:
[2025/06/24 17:51:27] [ info] [fluent bit] version=4.0.4, commit=af3d1b9e96, pid=3455327
[2025/06/24 17:51:27] [debug] [engine] coroutine stack size: 24576 bytes (24.0K)
[2025/06/24 17:51:27] [ info] [storage] ver=1.1.6, type=memory, sync=normal, checksum=off, max_chunks_up=128
[2025/06/24 17:51:27] [ info] [simd    ] disabled
[2025/06/24 17:51:27] [ info] [cmetrics] version=1.0.3
[2025/06/24 17:51:27] [ info] [ctraces ] version=0.6.6
[2025/06/24 17:51:27] [ info] [input:dummy:dummy.0] initializing
[2025/06/24 17:51:27] [ info] [input:dummy:dummy.0] storage_strategy='memory' (memory only)
[2025/06/24 17:51:27] [debug] [dummy:dummy.0] created event channels: read=25 write=26
[2025/06/24 17:51:27] [ info] [input:forward:forward.1] initializing
[2025/06/24 17:51:27] [ info] [output:forward:forward.1] worker #0 started
[2025/06/24 17:51:27] [ info] [output:stdout:stdout.0] worker #0 started
[2025/06/24 17:51:27] [ info] [output:forward:forward.1] worker #1 started
[2025/06/24 17:51:27] [ info] [input:forward:forward.1] storage_strategy='memory' (memory only)
[2025/06/24 17:51:27] [debug] [forward:forward.1] created event channels: read=27 write=28
[2025/06/24 17:51:27] [debug] [in_fw] Listen='0.0.0.0' TCP_Port=8888
[2025/06/24 17:51:27] [debug] [downstream] listening on 0.0.0.0:8888
[2025/06/24 17:51:27] [ info] [input:forward:forward.1] listening on 0.0.0.0:8888
[2025/06/24 17:51:27] [debug] [stdout:stdout.0] created event channels: read=30 write=31
[2025/06/24 17:51:27] [debug] [forward:forward.1] created event channels: read=39 write=40
[2025/06/24 17:51:27] [debug] [router] match rule dummy.0:forward.1
[2025/06/24 17:51:27] [debug] [router] match rule forward.1:stdout.0
[2025/06/24 17:51:27] [ info] [sp] stream processor started
[2025/06/24 17:51:27] [ info] [engine] Shutdown Grace Period=5, Shutdown Input Grace Period=2
[2025/06/24 17:51:29] [debug] [task] created task=0x6180190 id=0 OK
[2025/06/24 17:51:29] [debug] [output:forward:forward.1] task_id=0 assigned to thread #0
[2025/06/24 17:51:29] [debug] [output:forward:forward.1] request 36 bytes to flush
[2025/06/24 17:51:30] [debug] [upstream] KA connection #77 to localhost:8888 is connected
[2025/06/24 17:51:30] [debug] [upstream] KA connection #77 to localhost:8888 is now available
[2025/06/24 17:51:30] [debug] [out flush] cb_destroy coro_id=0
[2025/06/24 17:51:30] [debug] [task] destroy task=0x6180190 (task_id=0)
[0] fwd: [[1750801888.717285027, {}], {"message"=>"dummy"}]
[2025/06/24 17:51:30] [debug] [task] created task=0x633ce50 id=0 OK
[2025/06/24 17:51:30] [debug] [output:forward:forward.1] task_id=0 assigned to thread #1
[2025/06/24 17:51:30] [debug] [output:forward:forward.1] request 36 bytes to flush
[2025/06/24 17:51:30] [debug] [out flush] cb_destroy coro_id=0
[2025/06/24 17:51:30] [debug] [task] created task=0x633d060 id=1 OK
[2025/06/24 17:51:30] [debug] [upstream] KA connection #79 to localhost:8888 is connected
[2025/06/24 17:51:30] [debug] [output:stdout:stdout.0] task_id=1 assigned to thread #0
[2025/06/24 17:51:30] [debug] [upstream] KA connection #79 to localhost:8888 is now available
[2025/06/24 17:51:30] [debug] [task] destroy task=0x633d060 (task_id=1)
[2025/06/24 17:51:30] [debug] [out flush] cb_destroy coro_id=0
[2025/06/24 17:51:30] [debug] [task] destroy task=0x633ce50 (task_id=0)
[2025/06/24 17:51:31] [debug] [task] created task=0x63fbb50 id=0 OK
[2025/06/24 17:51:31] [debug] [output:forward:forward.1] task_id=0 assigned to thread #0
[2025/06/24 17:51:31] [debug] [task] created task=0x63fbc90 id=1 OK
[2025/06/24 17:51:31] [debug] [output:stdout:stdout.0] task_id=1 assigned to thread #0
[0] fwd: [[1750801889.733477064, {}], {"message"=>"dummy"}]
[2025/06/24 17:51:31] [debug] [output:forward:forward.1] request 36 bytes to flush
[2025/06/24 17:51:31] [debug] [upstream] KA connection #77 to localhost:8888 has been assigned (recycled)
[2025/06/24 17:51:31] [debug] [out flush] cb_destroy coro_id=1
[2025/06/24 17:51:31] [debug] [task] destroy task=0x63fbc90 (task_id=1)
[2025/06/24 17:51:31] [debug] [upstream] KA connection #77 to localhost:8888 is now available
[2025/06/24 17:51:31] [debug] [out flush] cb_destroy coro_id=1
[2025/06/24 17:51:31] [debug] [task] destroy task=0x63fbb50 (task_id=0)
[2025/06/24 17:51:32] [debug] [task] created task=0x6421570 id=0 OK
[2025/06/24 17:51:32] [debug] [output:forward:forward.1] task_id=0 assigned to thread #1
[0] fwd: [[1750801890.696708343, {}], {"message"=>"dummy"}]
[2025/06/24 17:51:32] [debug] [output:forward:forward.1] request 36 bytes to flush
[2025/06/24 17:51:32] [debug] [task] created task=0x6421780 id=1 OK
[2025/06/24 17:51:32] [debug] [upstream] KA connection #79 to localhost:8888 has been assigned (recycled)
[2025/06/24 17:51:32] [debug] [out flush] cb_destroy coro_id=2
[2025/06/24 17:51:32] [debug] [output:stdout:stdout.0] task_id=1 assigned to thread #0
[2025/06/24 17:51:32] [debug] [upstream] KA connection #79 to localhost:8888 is now available
[2025/06/24 17:51:32] [debug] [task] destroy task=0x6421570 (task_id=0)
[2025/06/24 17:51:32] [debug] [out flush] cb_destroy coro_id=1
[2025/06/24 17:51:32] [debug] [task] destroy task=0x6421780 (task_id=1)
[2025/06/24 17:51:33] [debug] [task] created task=0x8e69020 id=0 OK
[2025/06/24 17:51:33] [debug] [output:forward:forward.1] task_id=0 assigned to thread #0
[0] fwd: [[1750801891.699510656, {}], {"message"=>"dummy"}]
[2025/06/24 17:51:33] [debug] [output:forward:forward.1] request 36 bytes to flush
[2025/06/24 17:51:33] [debug] [task] created task=0x8e69230 id=1 OK
[2025/06/24 17:51:33] [debug] [upstream] KA connection #77 to localhost:8888 has been assigned (recycled)
[2025/06/24 17:51:33] [debug] [out flush] cb_destroy coro_id=3
[2025/06/24 17:51:33] [debug] [output:stdout:stdout.0] task_id=1 assigned to thread #0
[2025/06/24 17:51:33] [debug] [upstream] KA connection #77 to localhost:8888 is now available
[2025/06/24 17:51:33] [debug] [task] destroy task=0x8e69230 (task_id=1)
[2025/06/24 17:51:33] [debug] [out flush] cb_destroy coro_id=2
[2025/06/24 17:51:33] [debug] [task] destroy task=0x8e69020 (task_id=0)
[2025/06/24 17:51:34] [debug] [task] created task=0x8f1f530 id=0 OK
[0] fwd: [[1750801892.739171101, {}], {"message"=>"dummy"}]
[2025/06/24 17:51:34] [debug] [output:forward:forward.1] task_id=0 assigned to thread #1
[2025/06/24 17:51:34] [debug] [output:forward:forward.1] request 36 bytes to flush
[2025/06/24 17:51:34] [debug] [task] created task=0x8f1f740 id=1 OK
[2025/06/24 17:51:34] [debug] [upstream] KA connection #79 to localhost:8888 has been assigned (recycled)
[2025/06/24 17:51:34] [debug] [out flush] cb_destroy coro_id=4
[2025/06/24 17:51:34] [debug] [output:stdout:stdout.0] task_id=1 assigned to thread #0
[2025/06/24 17:51:34] [debug] [upstream] KA connection #79 to localhost:8888 is now available
[2025/06/24 17:51:34] [debug] [task] destroy task=0x8f1f740 (task_id=1)
[2025/06/24 17:51:34] [debug] [out flush] cb_destroy coro_id=2
[2025/06/24 17:51:34] [debug] [task] destroy task=0x8f1f530 (task_id=0)
[0] fwd: [[1750801893.698098107, {}], {"message"=>"dummy"}]
[2025/06/24 17:51:35] [debug] [task] created task=0x8fd2700 id=0 OK
[2025/06/24 17:51:35] [debug] [output:forward:forward.1] task_id=0 assigned to thread #0
[2025/06/24 17:51:35] [debug] [task] created task=0x8fd2910 id=1 OK
[2025/06/24 17:51:35] [debug] [output:stdout:stdout.0] task_id=1 assigned to thread #0
[2025/06/24 17:51:35] [debug] [output:forward:forward.1] request 36 bytes to flush
[2025/06/24 17:51:35] [debug] [task] destroy task=0x8fd2910 (task_id=1)
[2025/06/24 17:51:35] [debug] [upstream] KA connection #77 to localhost:8888 has been assigned (recycled)
[2025/06/24 17:51:35] [debug] [out flush] cb_destroy coro_id=5
[2025/06/24 17:51:35] [debug] [task] destroy task=0x8fd2700 (task_id=0)
[2025/06/24 17:51:35] [debug] [upstream] KA connection #77 to localhost:8888 is now available
[2025/06/24 17:51:35] [debug] [out flush] cb_destroy coro_id=3
[2025/06/24 17:51:36] [debug] [task] created task=0x9088c50 id=0 OK
[2025/06/24 17:51:36] [debug] [output:forward:forward.1] task_id=0 assigned to thread #1
[0] fwd: [[1750801894.695393493, {}], {"message"=>"dummy"}]
[2025/06/24 17:51:36] [debug] [output:forward:forward.1] request 36 bytes to flush
[2025/06/24 17:51:36] [debug] [task] created task=0x9088e60 id=1 OK
[2025/06/24 17:51:36] [debug] [upstream] KA connection #79 to localhost:8888 has been assigned (recycled)
[2025/06/24 17:51:36] [debug] [out flush] cb_destroy coro_id=6
[2025/06/24 17:51:36] [debug] [output:stdout:stdout.0] task_id=1 assigned to thread #0
[2025/06/24 17:51:36] [debug] [upstream] KA connection #79 to localhost:8888 is now available
[2025/06/24 17:51:36] [debug] [task] destroy task=0x9088e60 (task_id=1)
[2025/06/24 17:51:36] [debug] [out flush] cb_destroy coro_id=3
[2025/06/24 17:51:36] [debug] [task] destroy task=0x9088c50 (task_id=0)
[2025/06/24 17:51:37] [debug] [task] created task=0x91410b0 id=0 OK
[2025/06/24 17:51:37] [debug] [output:forward:forward.1] task_id=0 assigned to thread #0
[0] fwd: [[1750801895.694262815, {}], {"message"=>"dummy"}]
[2025/06/24 17:51:37] [debug] [output:forward:forward.1] request 36 bytes to flush
[2025/06/24 17:51:37] [debug] [task] created task=0x91412c0 id=1 OK
[2025/06/24 17:51:37] [debug] [upstream] KA connection #77 to localhost:8888 has been assigned (recycled)
[2025/06/24 17:51:37] [debug] [out flush] cb_destroy coro_id=7
[2025/06/24 17:51:37] [debug] [output:stdout:stdout.0] task_id=1 assigned to thread #0
[2025/06/24 17:51:37] [debug] [task] destroy task=0x91412c0 (task_id=1)
[2025/06/24 17:51:37] [debug] [upstream] KA connection #77 to localhost:8888 is now available
[2025/06/24 17:51:37] [debug] [task] destroy task=0x91410b0 (task_id=0)
[2025/06/24 17:51:37] [debug] [out flush] cb_destroy coro_id=4
[0] fwd: [[1750801896.702237904, {}], {"message"=>"dummy"}]
[2025/06/24 17:51:38] [debug] [task] created task=0x91f75c0 id=0 OK
[2025/06/24 17:51:38] [debug] [output:forward:forward.1] task_id=0 assigned to thread #1
[2025/06/24 17:51:38] [debug] [out flush] cb_destroy coro_id=8
[2025/06/24 17:51:38] [debug] [task] created task=0x91f77d0 id=1 OK
[2025/06/24 17:51:38] [debug] [output:forward:forward.1] request 36 bytes to flush
[2025/06/24 17:51:38] [debug] [output:stdout:stdout.0] task_id=1 assigned to thread #0
[2025/06/24 17:51:38] [debug] [upstream] KA connection #79 to localhost:8888 has been assigned (recycled)
[2025/06/24 17:51:38] [debug] [task] destroy task=0x91f77d0 (task_id=1)
[2025/06/24 17:51:38] [debug] [upstream] KA connection #79 to localhost:8888 is now available
[2025/06/24 17:51:38] [debug] [task] destroy task=0x91f75c0 (task_id=0)
[2025/06/24 17:51:38] [debug] [out flush] cb_destroy coro_id=4
[2025/06/24 17:51:39] [debug] [task] created task=0x92aa880 id=0 OK
[2025/06/24 17:51:39] [debug] [output:forward:forward.1] task_id=0 assigned to thread #0
[0] fwd: [[1750801897.700112925, {}], {"message"=>"dummy"}]
[2025/06/24 17:51:39] [debug] [output:forward:forward.1] request 36 bytes to flush
[2025/06/24 17:51:39] [debug] [task] created task=0x92aaa90 id=1 OK
[2025/06/24 17:51:39] [debug] [upstream] KA connection #77 to localhost:8888 has been assigned (recycled)
[2025/06/24 17:51:39] [debug] [out flush] cb_destroy coro_id=9
[2025/06/24 17:51:39] [debug] [output:stdout:stdout.0] task_id=1 assigned to thread #0
[2025/06/24 17:51:39] [debug] [upstream] KA connection #77 to localhost:8888 is now available
[2025/06/24 17:51:39] [debug] [task] destroy task=0x92aaa90 (task_id=1)
[2025/06/24 17:51:39] [debug] [out flush] cb_destroy coro_id=5
[2025/06/24 17:51:39] [debug] [task] destroy task=0x92aa880 (task_id=0)
[2025/06/24 17:51:40] [debug] [task] created task=0x935da50 id=0 OK
[2025/06/24 17:51:40] [debug] [output:forward:forward.1] task_id=0 assigned to thread #1
[2025/06/24 17:51:40] [debug] [task] created task=0x935dc60 id=1 OK
[2025/06/24 17:51:40] [debug] [output:stdout:stdout.0] task_id=1 assigned to thread #0
[2025/06/24 17:51:40] [debug] [output:forward:forward.1] request 36 bytes to flush
[0] fwd: [[1750801898.697445422, {}], {"message"=>"dummy"}]
[2025/06/24 17:51:40] [debug] [upstream] KA connection #79 to localhost:8888 has been assigned (recycled)
[2025/06/24 17:51:40] [debug] [out flush] cb_destroy coro_id=10
[2025/06/24 17:51:40] [debug] [upstream] KA connection #79 to localhost:8888 is now available
[2025/06/24 17:51:40] [debug] [task] destroy task=0x935dc60 (task_id=1)
[2025/06/24 17:51:40] [debug] [out flush] cb_destroy coro_id=5
[2025/06/24 17:51:40] [debug] [task] destroy task=0x935da50 (task_id=0)
[2025/06/24 17:51:41] [debug] [task] created task=0x9413e70 id=0 OK
[2025/06/24 17:51:41] [debug] [output:forward:forward.1] task_id=0 assigned to thread #0
[0] fwd: [[1750801899.699193533, {}], {"message"=>"dummy"}]
[2025/06/24 17:51:41] [debug] [output:forward:forward.1] request 36 bytes to flush
[2025/06/24 17:51:41] [debug] [task] created task=0x942a8c0 id=1 OK
[2025/06/24 17:51:41] [debug] [upstream] KA connection #77 to localhost:8888 has been assigned (recycled)
[2025/06/24 17:51:41] [debug] [out flush] cb_destroy coro_id=11
[2025/06/24 17:51:41] [debug] [output:stdout:stdout.0] task_id=1 assigned to thread #0
[2025/06/24 17:51:41] [debug] [upstream] KA connection #77 to localhost:8888 is now available
[2025/06/24 17:51:41] [debug] [task] destroy task=0x9413e70 (task_id=0)
[2025/06/24 17:51:41] [debug] [out flush] cb_destroy coro_id=6
[2025/06/24 17:51:41] [debug] [task] destroy task=0x942a8c0 (task_id=1)
[0] fwd: [[1750801900.695594000, {}], {"message"=>"dummy"}]
[2025/06/24 17:51:42] [debug] [task] created task=0x943aca0 id=0 OK
[2025/06/24 17:51:42] [debug] [output:forward:forward.1] task_id=0 assigned to thread #1
[2025/06/24 17:51:42] [debug] [output:forward:forward.1] request 36 bytes to flush
[2025/06/24 17:51:42] [debug] [out flush] cb_destroy coro_id=12
[2025/06/24 17:51:42] [debug] [task] created task=0x943aeb0 id=1 OK
[2025/06/24 17:51:42] [debug] [upstream] KA connection #79 to localhost:8888 has been assigned (recycled)
[2025/06/24 17:51:42] [debug] [output:stdout:stdout.0] task_id=1 assigned to thread #0
[2025/06/24 17:51:42] [debug] [upstream] KA connection #79 to localhost:8888 is now available
[2025/06/24 17:51:42] [debug] [task] destroy task=0x943aeb0 (task_id=1)
[2025/06/24 17:51:42] [debug] [out flush] cb_destroy coro_id=6
[2025/06/24 17:51:42] [debug] [task] destroy task=0x943aca0 (task_id=0)
[2025/06/24 17:51:43] [debug] [task] created task=0x957c280 id=0 OK
[2025/06/24 17:51:43] [debug] [output:forward:forward.1] task_id=0 assigned to thread #0
[2025/06/24 17:51:43] [debug] [task] created task=0x957c490 id=1 OK
[0] fwd: [[1750801901.698105469, {}], {"message"=>"dummy"}]
[2025/06/24 17:51:43] [debug] [output:forward:forward.1] request 36 bytes to flush
[2025/06/24 17:51:43] [debug] [output:stdout:stdout.0] task_id=1 assigned to thread #0
[2025/06/24 17:51:43] [debug] [upstream] KA connection #77 to localhost:8888 has been assigned (recycled)
[2025/06/24 17:51:43] [debug] [task] destroy task=0x957c280 (task_id=0)
[2025/06/24 17:51:43] [debug] [upstream] KA connection #77 to localhost:8888 is now available
[2025/06/24 17:51:43] [debug] [out flush] cb_destroy coro_id=13
[2025/06/24 17:51:43] [debug] [task] destroy task=0x957c490 (task_id=1)
[2025/06/24 17:51:43] [debug] [out flush] cb_destroy coro_id=7
^C[2025/06/24 17:51:44] [engine] caught signal (SIGINT)
[2025/06/24 17:51:44] [debug] [task] created task=0x96326f0 id=0 OK
[2025/06/24 17:51:44] [debug] [output:forward:forward.1] task_id=0 assigned to thread #1
[2025/06/24 17:51:44] [debug] [output:forward:forward.1] request 36 bytes to flush
[2025/06/24 17:51:44] [debug] [task] created task=0x9638ca0 id=1 OK
[2025/06/24 17:51:44] [debug] [upstream] KA connection #79 to localhost:8888 has been assigned (recycled)
[2025/06/24 17:51:44] [debug] [output:stdout:stdout.0] task_id=1 assigned to thread #0
[2025/06/24 17:51:44] [debug] [upstream] KA connection #79 to localhost:8888 is now available
[2025/06/24 17:51:44] [debug] [out flush] cb_destroy coro_id=7
[0] fwd: [[1750801902.699511537, {}], {"message"=>"dummy"}]
==3455327== Thread 2 flb-pipeline:
==3455327== Conditional jump or move depends on uninitialised value(s)
==3455327==    at 0x52CFE85: __vfprintf_internal (vfprintf-internal.c:1516)
==3455327==    by 0x52E2499: __vsnprintf_internal (vsnprintf.c:114)
==3455327==    by 0x24640D: flb_log_construct (flb_log.c:747)
==3455327==    by 0x2466E7: flb_log_print (flb_log.c:810)
==3455327==    by 0x2BAE69: flb_engine_reschedule_retries (flb_engine.c:136)
==3455327==    by 0x2BD0E2: flb_engine_start (flb_engine.c:1005)
==3455327==    by 0x240BDE: flb_lib_worker (flb_lib.c:835)
==3455327==    by 0x52EEAC2: start_thread (pthread_create.c:442)
==3455327==    by 0x537FA03: clone (clone.S:100)
==3455327== 
==3455327== Use of uninitialised value of size 8
==3455327==    at 0x52B428A: _itoa_word (_itoa.c:178)
==3455327==    by 0x52CFABD: __vfprintf_internal (vfprintf-internal.c:1516)
==3455327==    by 0x52E2499: __vsnprintf_internal (vsnprintf.c:114)
==3455327==    by 0x24640D: flb_log_construct (flb_log.c:747)
==3455327==    by 0x2466E7: flb_log_print (flb_log.c:810)
==3455327==    by 0x2BAE69: flb_engine_reschedule_retries (flb_engine.c:136)
==3455327==    by 0x2BD0E2: flb_engine_start (flb_engine.c:1005)
==3455327==    by 0x240BDE: flb_lib_worker (flb_lib.c:835)
==3455327==    by 0x52EEAC2: start_thread (pthread_create.c:442)
==3455327==    by 0x537FA03: clone (clone.S:100)
==3455327== 
==3455327== Conditional jump or move depends on uninitialised value(s)
==3455327==    at 0x52B429C: _itoa_word (_itoa.c:178)
==3455327==    by 0x52CFABD: __vfprintf_internal (vfprintf-internal.c:1516)
==3455327==    by 0x52E2499: __vsnprintf_internal (vsnprintf.c:114)
==3455327==    by 0x24640D: flb_log_construct (flb_log.c:747)
==3455327==    by 0x2466E7: flb_log_print (flb_log.c:810)
==3455327==    by 0x2BAE69: flb_engine_reschedule_retries (flb_engine.c:136)
==3455327==    by 0x2BD0E2: flb_engine_start (flb_engine.c:1005)
==3455327==    by 0x240BDE: flb_lib_worker (flb_lib.c:835)
==3455327==    by 0x52EEAC2: start_thread (pthread_create.c:442)
==3455327==    by 0x537FA03: clone (clone.S:100)
==3455327== 
==3455327== Conditional jump or move depends on uninitialised value(s)
==3455327==    at 0x52D05C3: __vfprintf_internal (vfprintf-internal.c:1516)
==3455327==    by 0x52E2499: __vsnprintf_internal (vsnprintf.c:114)
==3455327==    by 0x24640D: flb_log_construct (flb_log.c:747)
==3455327==    by 0x2466E7: flb_log_print (flb_log.c:810)
==3455327==    by 0x2BAE69: flb_engine_reschedule_retries (flb_engine.c:136)
==3455327==    by 0x2BD0E2: flb_engine_start (flb_engine.c:1005)
==3455327==    by 0x240BDE: flb_lib_worker (flb_lib.c:835)
==3455327==    by 0x52EEAC2: start_thread (pthread_create.c:442)
==3455327==    by 0x537FA03: clone (clone.S:100)
==3455327== 
==3455327== Conditional jump or move depends on uninitialised value(s)
==3455327==    at 0x52CFC05: __vfprintf_internal (vfprintf-internal.c:1516)
==3455327==    by 0x52E2499: __vsnprintf_internal (vsnprintf.c:114)
==3455327==    by 0x24640D: flb_log_construct (flb_log.c:747)
==3455327==    by 0x2466E7: flb_log_print (flb_log.c:810)
==3455327==    by 0x2BAE69: flb_engine_reschedule_retries (flb_engine.c:136)
==3455327==    by 0x2BD0E2: flb_engine_start (flb_engine.c:1005)
==3455327==    by 0x240BDE: flb_lib_worker (flb_lib.c:835)
==3455327==    by 0x52EEAC2: start_thread (pthread_create.c:442)
==3455327==    by 0x537FA03: clone (clone.S:100)
==3455327== 
[2025/06/24 17:51:44] [ warn] [engine] service will shutdown in max 5 seconds
[2025/06/24 17:51:44] [debug] [engine] retry=0x6c2d130 for task 0 already scheduled to run, not re-scheduling it.
[2025/06/24 17:51:44] [debug] [upstream] KA connection #79 to localhost:8888 has been disconnected by the remote service
[2025/06/24 17:51:44] [debug] [engine] retry=0x6c2d130 for task 1 already scheduled to run, not re-scheduling it.
[2025/06/24 17:51:44] [ info] [input] pausing dummy.0
[2025/06/24 17:51:44] [debug] [upstream] KA connection #77 to localhost:8888 has been disconnected by the remote service
[2025/06/24 17:51:44] [debug] [out flush] cb_destroy coro_id=14
[2025/06/24 17:51:44] [ info] [input] pausing forward.1
[2025/06/24 17:51:44] [debug] [task] destroy task=0x96326f0 (task_id=0)
[2025/06/24 17:51:44] [debug] [task] destroy task=0x9638ca0 (task_id=1)
[2025/06/24 17:51:44] [ info] [engine] service has stopped (0 pending tasks)
[2025/06/24 17:51:44] [ info] [input] pausing dummy.0
[2025/06/24 17:51:44] [ info] [input] pausing forward.1
[2025/06/24 17:51:44] [ info] [output:stdout:stdout.0] thread worker #0 stopping...
[2025/06/24 17:51:44] [ info] [output:stdout:stdout.0] thread worker #0 stopped
[2025/06/24 17:51:44] [ info] [output:forward:forward.1] thread worker #0 stopping...
[2025/06/24 17:51:44] [ info] [output:forward:forward.1] thread worker #0 stopped
[2025/06/24 17:51:44] [ info] [output:forward:forward.1] thread worker #1 stopping...
[2025/06/24 17:51:44] [ info] [output:forward:forward.1] thread worker #1 stopped
==3455327== 
==3455327== HEAP SUMMARY:
==3455327==     in use at exit: 0 bytes in 0 blocks
==3455327==   total heap usage: 5,768 allocs, 5,768 frees, 14,393,982 bytes allocated
==3455327== 
==3455327== All heap blocks were freed -- no leaks are possible
==3455327== 
==3455327== Use --track-origins=yes to see where uninitialised values come from
==3455327== For lists of detected and suppressed errors, rerun with: -s
==3455327== ERROR SUMMARY: 34 errors from 5 contexts (suppressed: 0 from 0)

If this is a change to packaging of containers or native binaries then please confirm it works for all targets.

  • Run local packaging test showing all targets (including any new ones) build.
  • Set ok-package-test label to test for all targets (requires maintainer to do).

Documentation

  • Documentation required for this feature

Backporting

  • Backport to latest stable release.

Fluent Bit is licensed under Apache 2.0, by submitting this pull request I understand that this code will be released under the terms of that license.

@lecaros
upstream: prioritize the reuse of connections instead of establishing…
af3d1b9 
… new ones

Signed-off-by: lecaros <lecaros@calyptia.com>
@lecaros lecaros force-pushed the lecaros-change-available-connections-handling branch from f303baa to af3d1b9 Compare June 18, 2025 00:07
@lecaros lecaros marked this pull request as ready for review June 24, 2025 21:57
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Reviewers

@edsiper edsiper Awaiting requested review from edsiper edsiper is a code owner

@leonardo-albertovich leonardo-albertovich Awaiting requested review from leonardo-albertovich leonardo-albertovich is a code owner

@fujimotos fujimotos Awaiting requested review from fujimotos fujimotos is a code owner

@koleini koleini Awaiting requested review from koleini koleini is a code owner

At least 1 approving review is required to merge this pull request.

Assignees
No one assigned
Labels
docs-required
Projects
None yet
Milestone
No milestone
Development

Successfully merging this pull request may close these issues.
1 participant
@lecaros