elasticsearch icon indicating copy to clipboard operation
elasticsearch copied to clipboard

Operator/ingest

Open grcevski opened this issue 2 years ago • 4 comments

This PR adds support for /_ingest/pipeline for file based settings.

Relates to https://github.com/elastic/elasticsearch/issues/89183

grcevski avatar Aug 30 '22 18:08 grcevski

Pinging @elastic/es-core-infra (Team:Core/Infra)

elasticsearchmachine avatar Sep 19 '22 16:09 elasticsearchmachine

Hi @grcevski, I've created a changelog YAML for you.

elasticsearchmachine avatar Sep 19 '22 16:09 elasticsearchmachine

I left a few comments, I'm unsure about the preTransform piece. I understand we need the ingest infos, but I wonder if there is a better way to track it somehow so that validation could not require it. What do you think?

Yeah good point, let me go back and look at ways we can do without it. It complicates things quite a bit, for such a small thing. I'll address the rest of the feedback based on what I manage to do here.

grcevski avatar Sep 19 '22 22:09 grcevski

I pushed an update to see if all tests pass, this seems like a simpler change and more efficient, since we don't expect node configuration to change that much along with file based settings. We keep the node infos cached in the file settings service, and we only refresh them when some nodes have changed.

I need to write extra tests for that logic, make sure we set the flag correctly when nodes are added and removed. I initially thought I only need to track the adds, but removes are needed in case the last ingest capable node is removed.

grcevski avatar Sep 20 '22 23:09 grcevski

I reworked how the node infos were being called, it's done on demand and only if nodes have joined/left the cluster. I also just pushed an update with new tests that ensure the nodeInfos are fetched correctly and at the right time.

grcevski avatar Sep 21 '22 16:09 grcevski

@elasticsearchmachine run elasticsearch-ci/part-2

grcevski avatar Sep 27 '22 17:09 grcevski

Thanks Lee!

grcevski avatar Sep 27 '22 18:09 grcevski