Daijiro Fukuda

Sorry for my late response. > So even if during host maintenance or clean restarts I don’t think there will be process duplication. I see... > Is there any flag...

@pecastro Thanks for your report! If OOM forcibly kills the process, files that are being written may become broken. That's not a problem on the application side. Please operate the...

I see! Thanks for your report! So, the cause of this issue may be the memory shortage. If you find other causes, please reopen this issue!

> However, I'm concerned that caller_plugin_id has a race condition, although I don't confirm it. It looks to me that the id can be another plugin-id running concurrently... https://github.com/fluent/fluentd/blob/51b860b1be2eb59076d706fda12d55657a614c8f/lib/fluent/plugin_helper/event_emitter.rb#L27-L36

A simple check seems ok. But may occur with more load. ```xml @type sample tag test.foo @type sample tag test.bar @type sample tag test.boo @type parser @id foo key_name not-exist...

I've succeeded in reproducing the race condition. * Run 3 `in_samples` with `rate 100` (100 emits/s) in concurrent. * Make each filter plugin raise an error. * Check Fluentd log....

> However, I'm concerned that `caller_plugin_id` has a race condition, although I don't confirm it. > It looks to me that the id can be another plugin-id running concurrently... >...

Looks like ipv6 is not supported in case of single worker. https://github.com/fluent/fluentd/blob/v1.17.0/lib/fluent/plugin_helper/server.rb#L370-L383

> Looks like ipv6 is not supported in case of single worker. > > https://github.com/fluent/fluentd/blob/v1.17.0/lib/fluent/plugin_helper/server.rb#L370-L383 Hmm, we can't add brackets? ```rb Addrinfo.tcp("::", 20000) => # Addrinfo.tcp("[::]", 20000) (irb):1:in `tcp': getaddrinfo:...

> Hmm, we can't add brackets? This works. ```xml @type forward bind "::" port 12345 ```