Skip to content

Conversation

@luigidellaquila
Copy link
Contributor

Adding a test with a pipeline breaker + ENRICH in local mode, where the policy only exists on local cluster

@luigidellaquila luigidellaquila added >test Issues or PRs that are addressing/adding tests :Analytics/ES|QL AKA ESQL labels Sep 5, 2025
@elasticsearchmachine
Copy link
Collaborator

Pinging @elastic/es-analytical-engine (Team:Analytics)

@elasticsearchmachine elasticsearchmachine added Team:Analytics Meta label for analytical engine team (ESQL/Aggs/Geo) v9.2.0 labels Sep 5, 2025
Comment on lines +115 to +117
String query = "FROM *:events | eval ip= TO_STR(host) | "
+ enrichHostsLocal(Enrich.Mode.COORDINATOR)
+ " | stats c = COUNT(*) by os | SORT os";
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Is eval ip= acting as a PipelineBreaker here?
I am not sure why enrich is in coordinator mode here. Could it be any or randomFrom(..)?

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

No, in that case eval is not a pipeline breaker, I believe ENRICH becomes the actual breaker, as it's in COORDINATOR mode.

The real test is a few lines below, where I have a STATS by ip before ENRICH

@luigidellaquila luigidellaquila enabled auto-merge (squash) September 5, 2025 08:10
@alex-spies
Copy link
Contributor

Cc @smalyshev for awareness (who's currently working on making remote ENRICH saner)

@luigidellaquila luigidellaquila merged commit d113355 into elastic:main Sep 5, 2025
32 checks passed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

:Analytics/ES|QL AKA ESQL Team:Analytics Meta label for analytical engine team (ESQL/Aggs/Geo) >test Issues or PRs that are addressing/adding tests v9.2.0

Projects

None yet

Development

Successfully merging this pull request may close these issues.

4 participants