Skip to content

DSL waits for the tsdb time boundaries to lapse#100470

Merged
andreidan merged 6 commits intoelastic:mainfrom
andreidan:dsl-wait-for-end-time
Oct 11, 2023
Merged

DSL waits for the tsdb time boundaries to lapse#100470
andreidan merged 6 commits intoelastic:mainfrom
andreidan:dsl-wait-for-end-time

Conversation

@andreidan
Copy link
Copy Markdown
Contributor

TSDB indices are expected to receive a large amount of writes whilst their time bounds are "active" (i.e. they include now). This ensures TSDB doesn't execute any ingest disruptive operations (like delete, forcemerge, downsample) until the end_time for the TSDS backing indices has lapsed.

Fixes #99696

TSDB indices are expected to receive a large amounts of writes whilst
their time bounds are "active" (i.e they include `now`).
This ensures TSDB doesn't execute any ingest disruptive operations (like
delete, forcemerge, downsample) until the `end_time` for the TSDS
backing indices has lapsed.
@elasticsearchmachine elasticsearchmachine added the Team:Data Management (obsolete) DO NOT USE. This team no longer exists. label Oct 8, 2023
@elasticsearchmachine
Copy link
Copy Markdown
Collaborator

Pinging @elastic/es-data-management (Team:Data Management)

@elasticsearchmachine
Copy link
Copy Markdown
Collaborator

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

@andreidan
Copy link
Copy Markdown
Contributor Author

@elasticmachine update branch

Copy link
Copy Markdown
Member

@masseyke masseyke left a comment

Choose a reason for hiding this comment

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

As we discussed offline, the code changes look great to me. We don't actually have any integration test coverage though (the changes to integration tests are just to get them compiling). It would be fairly hard to integration test this. I assume we could do something that would artificially get some TSDB indices in the state we want, and then do a test something like DataStreamLifecycleServiceIT.testAutomaticForceMerge(), but I don't know how to do that, or if it is even possible.

Copy link
Copy Markdown
Member

@martijnvg martijnvg left a comment

Choose a reason for hiding this comment

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

lgtm

@elasticsearchmachine
Copy link
Copy Markdown
Collaborator

💚 Backport successful

Status Branch Result
8.11

andreidan added a commit to andreidan/elasticsearch that referenced this pull request Oct 11, 2023
TSDB indices are expected to receive a large amounts of writes whilst
their time bounds are "active" (i.e they include `now`).
This ensures TSDB doesn't execute any ingest disruptive operations (like
delete, forcemerge, downsample) until the `end_time` for the TSDS
backing indices has lapsed.
elasticsearchmachine pushed a commit that referenced this pull request Oct 11, 2023
TSDB indices are expected to receive a large amounts of writes whilst
their time bounds are "active" (i.e they include `now`).
This ensures TSDB doesn't execute any ingest disruptive operations (like
delete, forcemerge, downsample) until the `end_time` for the TSDS
backing indices has lapsed.
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

>bug :StorageEngine/Data streams Data streams and their lifecycles Team:Data Management (obsolete) DO NOT USE. This team no longer exists. v8.11.1 v8.12.0

Projects

None yet

Development

Successfully merging this pull request may close these issues.

TSDS data streams can route writes to downsampled indices after rollover

5 participants