SQL input plugin

[mudim]

Hi all, hope all well. Looking for some clarification around sql input plugin, in context of logs.
https://github.com/fluent/fluent-plugin-sql

Documentation is clear on how the state is maintained so that we don't fetch same records on restarts. However, when deployed as daemonset, want to understand how the state is replicated across the plugins (one one each pod). Because, if the state is not replicated, wouldn't each of the input query same data there by duplicating log records?

Cheers

[daipom]

I'm not familiar with k8s, but if you collect data outside of the instance, then it would be necessary to put the state file outside as well, I think.