Skip to content

Add Channel Factory parameter to Translog#18918

Merged
cwperks merged 16 commits intoopensearch-project:mainfrom
RajatGupta02:translog_overload
Aug 27, 2025
Merged

Add Channel Factory parameter to Translog#18918
cwperks merged 16 commits intoopensearch-project:mainfrom
RajatGupta02:translog_overload

Conversation

@RajatGupta02
Copy link
Copy Markdown
Contributor

Description

Adds a channel factory parameter to translog constructor which was earlier always defaulted to FileChannel::open. This enables us to pass our own channel factory which was not possible by overriding otherwise.

Related Issues

Related:

Check List

  • Functionality includes testing.
  • API changes companion pull request created, if applicable.
  • Public documentation issue/PR created, if applicable.

By submitting this pull request, I confirm that my contribution is made under the terms of the Apache 2.0 license.
For more information on following Developer Certificate of Origin and signing off your commits, please check here.

@RajatGupta02
Copy link
Copy Markdown
Contributor Author

cc: @andrross @sachinpkale @kumargu @cwperks

@github-actions
Copy link
Copy Markdown
Contributor

github-actions bot commented Aug 5, 2025

❌ Gradle check result for a311a41: FAILURE

Please examine the workflow log, locate, and copy-paste the failure(s) below, then iterate to green. Is the failure a flaky test unrelated to your change?

@github-actions
Copy link
Copy Markdown
Contributor

github-actions bot commented Aug 5, 2025

❌ Gradle check result for 5bb9f00: FAILURE

Please examine the workflow log, locate, and copy-paste the failure(s) below, then iterate to green. Is the failure a flaky test unrelated to your change?

@cwperks
Copy link
Copy Markdown
Member

cwperks commented Aug 6, 2025

@RajatGupta02 please add a CHANGELOG entry for this. Please note that the CHANGELOG may be reset tomorrow post code-freeze.

@github-actions
Copy link
Copy Markdown
Contributor

github-actions bot commented Aug 6, 2025

❕ Gradle check result for 5bb9f00: UNSTABLE

Please review all flaky tests that succeeded after retry and create an issue if one does not already exist to track the flaky failure.

@codecov
Copy link
Copy Markdown

codecov bot commented Aug 6, 2025

Codecov Report

❌ Patch coverage is 57.14286% with 3 lines in your changes missing coverage. Please review.
✅ Project coverage is 72.93%. Comparing base (669ec8d) to head (4c8df69).
⚠️ Report is 9 commits behind head on main.

Files with missing lines Patch % Lines
...a/org/opensearch/index/translog/LocalTranslog.java 0.00% 2 Missing ⚠️
...n/java/org/opensearch/index/translog/Translog.java 80.00% 1 Missing ⚠️
Additional details and impacted files
@@             Coverage Diff              @@
##               main   #18918      +/-   ##
============================================
- Coverage     72.96%   72.93%   -0.03%     
- Complexity    69486    69512      +26     
============================================
  Files          5648     5648              
  Lines        319329   319334       +5     
  Branches      46194    46195       +1     
============================================
- Hits         232993   232922      -71     
- Misses        67516    67638     +122     
+ Partials      18820    18774      -46     

☔ View full report in Codecov by Sentry.
📢 Have feedback on the report? Share it here.

🚀 New features to boost your workflow:
  • ❄️ Test Analytics: Detect flaky tests, report on failures, and find test suite problems.

@github-actions
Copy link
Copy Markdown
Contributor

github-actions bot commented Aug 6, 2025

✅ Gradle check result for b258b88: SUCCESS

Rajat Gupta added 2 commits August 26, 2025 19:40
Signed-off-by: Rajat Gupta <gptrajat@amazon.com>
Signed-off-by: Rajat Gupta <gptrajat@amazon.com>
Signed-off-by: Rajat Gupta <gptrajat@amazon.com>
@github-actions
Copy link
Copy Markdown
Contributor

✅ Gradle check result for 6a3eced: SUCCESS

Signed-off-by: Craig Perkins <cwperx@amazon.com>
@github-actions
Copy link
Copy Markdown
Contributor

❌ Gradle check result for 51b082c: FAILURE

Please examine the workflow log, locate, and copy-paste the failure(s) below, then iterate to green. Is the failure a flaky test unrelated to your change?

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>
@github-actions
Copy link
Copy Markdown
Contributor

❌ Gradle check result for 4c8df69: FAILURE

Please examine the workflow log, locate, and copy-paste the failure(s) below, then iterate to green. Is the failure a flaky test unrelated to your change?

@github-actions
Copy link
Copy Markdown
Contributor

✅ Gradle check result for 4c8df69: SUCCESS

@cwperks cwperks merged commit 981127d into opensearch-project:main Aug 27, 2025
31 of 34 checks passed
atris added a commit to atris/OpenSearch that referenced this pull request Aug 28, 2025
* Add overload for channelFactory

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Fix tests

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Add Changelog entry

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Fix conflicts

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* When update operations fail during preparation (e.g., version conflicts), (opensearch-project#18917)

TransportShardBulkAction still triggers refresh even though no actual
  writes occurred. This fix checks if locationToSync is null (indicating
  no writes) and prevents refresh in such cases.

  Fixes opensearch-project#15261

Signed-off-by: Atri Sharma <atri.jiit@gmail.com>

* Remove all entries from changelog to be released in 3.2 (opensearch-project#18989)

Signed-off-by: Andrew Ross <andrross@amazon.com>

* Add temporal routing processors for time-based document routing (opensearch-project#18966)

Implements TemporalRoutingProcessor for ingest pipelines and
TemporalRoutingSearchProcessor for search pipelines based on RFC opensearch-project#18920.

 Features:
 - Route documents to shards based on timestamp fields
 - Support hour, day, week, and month granularities
 - Optional hash bucketing for better distribution
 - Automatic search routing to relevant time ranges
 - ISO week format support

The processors enable efficient time-based data organization for
log and metrics workloads by co-locating documents from the same
time period on the same shards.

---------

Signed-off-by: Atri Sharma <atri.jiit@gmail.com>

* Add CompletionStage variants to methods in the Client Interface and default to ActionListener impl (opensearch-project#18998)

* Add CompletableFuture variables to methods in the Client Interface and default to ActionListener impl

Signed-off-by: Craig Perkins <cwperx@amazon.com>

* Add to CHANGELOG

Signed-off-by: Craig Perkins <cwperx@amazon.com>

* Fix typo in CHANGELOG

Signed-off-by: Craig Perkins <cwperx@amazon.com>

* Switch to CompletionStage

Signed-off-by: Craig Perkins <cwperx@amazon.com>

* Update CHANGELOG entry

Signed-off-by: Craig Perkins <cwperx@amazon.com>

---------

Signed-off-by: Craig Perkins <cwperx@amazon.com>

* Expand fetch phase profiling to support inner hits and top hits aggregation phases (opensearch-project#18936)


---------

Signed-off-by: Andre van de Ven <andrebvandeven@gmail.com>
Signed-off-by: Andre van de Ven <113951599+andrevandeven@users.noreply.github.com>
Signed-off-by: Andre van de Ven <andrevdv@amazon.com>
Co-authored-by: Andre van de Ven <andrevdv@amazon.com>

* IllegalArgumentException when scroll ID has a node no longer part of the Cluster (opensearch-project#19031)



---------

Signed-off-by: Anurag Rai <anurag.rai@uber.com>
Signed-off-by: Anurag Rai <91844619+anuragrai16@users.noreply.github.com>

* Add Changelog entry

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Add secondary constructor

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Modify changelog

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Update changelog

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Add another constructor to fix breaking change check

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

---------

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>
Signed-off-by: Atri Sharma <atri.jiit@gmail.com>
Signed-off-by: Andrew Ross <andrross@amazon.com>
Signed-off-by: Craig Perkins <cwperx@amazon.com>
Signed-off-by: Andre van de Ven <andrebvandeven@gmail.com>
Signed-off-by: Andre van de Ven <113951599+andrevandeven@users.noreply.github.com>
Signed-off-by: Andre van de Ven <andrevdv@amazon.com>
Signed-off-by: Anurag Rai <anurag.rai@uber.com>
Signed-off-by: Anurag Rai <91844619+anuragrai16@users.noreply.github.com>
Co-authored-by: Rajat Gupta <gptrajat@amazon.com>
Co-authored-by: Atri Sharma <atri.jiit@gmail.com>
Co-authored-by: Andrew Ross <andrross@amazon.com>
Co-authored-by: Craig Perkins <cwperx@amazon.com>
Co-authored-by: Andre van de Ven <113951599+andrevandeven@users.noreply.github.com>
Co-authored-by: Andre van de Ven <andrevdv@amazon.com>
Co-authored-by: Anurag Rai <91844619+anuragrai16@users.noreply.github.com>
pranikum pushed a commit to pranikum/OpenSearch that referenced this pull request Sep 4, 2025
* Add overload for channelFactory

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Fix tests

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Add Changelog entry

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Fix conflicts

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* When update operations fail during preparation (e.g., version conflicts), (opensearch-project#18917)

TransportShardBulkAction still triggers refresh even though no actual
  writes occurred. This fix checks if locationToSync is null (indicating
  no writes) and prevents refresh in such cases.

  Fixes opensearch-project#15261

Signed-off-by: Atri Sharma <atri.jiit@gmail.com>

* Remove all entries from changelog to be released in 3.2 (opensearch-project#18989)

Signed-off-by: Andrew Ross <andrross@amazon.com>

* Add temporal routing processors for time-based document routing (opensearch-project#18966)

Implements TemporalRoutingProcessor for ingest pipelines and
TemporalRoutingSearchProcessor for search pipelines based on RFC opensearch-project#18920.

 Features:
 - Route documents to shards based on timestamp fields
 - Support hour, day, week, and month granularities
 - Optional hash bucketing for better distribution
 - Automatic search routing to relevant time ranges
 - ISO week format support

The processors enable efficient time-based data organization for
log and metrics workloads by co-locating documents from the same
time period on the same shards.

---------

Signed-off-by: Atri Sharma <atri.jiit@gmail.com>

* Add CompletionStage variants to methods in the Client Interface and default to ActionListener impl (opensearch-project#18998)

* Add CompletableFuture variables to methods in the Client Interface and default to ActionListener impl

Signed-off-by: Craig Perkins <cwperx@amazon.com>

* Add to CHANGELOG

Signed-off-by: Craig Perkins <cwperx@amazon.com>

* Fix typo in CHANGELOG

Signed-off-by: Craig Perkins <cwperx@amazon.com>

* Switch to CompletionStage

Signed-off-by: Craig Perkins <cwperx@amazon.com>

* Update CHANGELOG entry

Signed-off-by: Craig Perkins <cwperx@amazon.com>

---------

Signed-off-by: Craig Perkins <cwperx@amazon.com>

* Expand fetch phase profiling to support inner hits and top hits aggregation phases (opensearch-project#18936)


---------

Signed-off-by: Andre van de Ven <andrebvandeven@gmail.com>
Signed-off-by: Andre van de Ven <113951599+andrevandeven@users.noreply.github.com>
Signed-off-by: Andre van de Ven <andrevdv@amazon.com>
Co-authored-by: Andre van de Ven <andrevdv@amazon.com>

* IllegalArgumentException when scroll ID has a node no longer part of the Cluster (opensearch-project#19031)



---------

Signed-off-by: Anurag Rai <anurag.rai@uber.com>
Signed-off-by: Anurag Rai <91844619+anuragrai16@users.noreply.github.com>

* Add Changelog entry

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Add secondary constructor

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Modify changelog

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Update changelog

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Add another constructor to fix breaking change check

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

---------

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>
Signed-off-by: Atri Sharma <atri.jiit@gmail.com>
Signed-off-by: Andrew Ross <andrross@amazon.com>
Signed-off-by: Craig Perkins <cwperx@amazon.com>
Signed-off-by: Andre van de Ven <andrebvandeven@gmail.com>
Signed-off-by: Andre van de Ven <113951599+andrevandeven@users.noreply.github.com>
Signed-off-by: Andre van de Ven <andrevdv@amazon.com>
Signed-off-by: Anurag Rai <anurag.rai@uber.com>
Signed-off-by: Anurag Rai <91844619+anuragrai16@users.noreply.github.com>
Co-authored-by: Rajat Gupta <gptrajat@amazon.com>
Co-authored-by: Atri Sharma <atri.jiit@gmail.com>
Co-authored-by: Andrew Ross <andrross@amazon.com>
Co-authored-by: Craig Perkins <cwperx@amazon.com>
Co-authored-by: Andre van de Ven <113951599+andrevandeven@users.noreply.github.com>
Co-authored-by: Andre van de Ven <andrevdv@amazon.com>
Co-authored-by: Anurag Rai <91844619+anuragrai16@users.noreply.github.com>
kh3ra pushed a commit to kh3ra/OpenSearch that referenced this pull request Sep 5, 2025
* Add overload for channelFactory

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Fix tests

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Add Changelog entry

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Fix conflicts

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* When update operations fail during preparation (e.g., version conflicts), (opensearch-project#18917)

TransportShardBulkAction still triggers refresh even though no actual
  writes occurred. This fix checks if locationToSync is null (indicating
  no writes) and prevents refresh in such cases.

  Fixes opensearch-project#15261

Signed-off-by: Atri Sharma <atri.jiit@gmail.com>

* Remove all entries from changelog to be released in 3.2 (opensearch-project#18989)

Signed-off-by: Andrew Ross <andrross@amazon.com>

* Add temporal routing processors for time-based document routing (opensearch-project#18966)

Implements TemporalRoutingProcessor for ingest pipelines and
TemporalRoutingSearchProcessor for search pipelines based on RFC opensearch-project#18920.

 Features:
 - Route documents to shards based on timestamp fields
 - Support hour, day, week, and month granularities
 - Optional hash bucketing for better distribution
 - Automatic search routing to relevant time ranges
 - ISO week format support

The processors enable efficient time-based data organization for
log and metrics workloads by co-locating documents from the same
time period on the same shards.

---------

Signed-off-by: Atri Sharma <atri.jiit@gmail.com>

* Add CompletionStage variants to methods in the Client Interface and default to ActionListener impl (opensearch-project#18998)

* Add CompletableFuture variables to methods in the Client Interface and default to ActionListener impl

Signed-off-by: Craig Perkins <cwperx@amazon.com>

* Add to CHANGELOG

Signed-off-by: Craig Perkins <cwperx@amazon.com>

* Fix typo in CHANGELOG

Signed-off-by: Craig Perkins <cwperx@amazon.com>

* Switch to CompletionStage

Signed-off-by: Craig Perkins <cwperx@amazon.com>

* Update CHANGELOG entry

Signed-off-by: Craig Perkins <cwperx@amazon.com>

---------

Signed-off-by: Craig Perkins <cwperx@amazon.com>

* Expand fetch phase profiling to support inner hits and top hits aggregation phases (opensearch-project#18936)


---------

Signed-off-by: Andre van de Ven <andrebvandeven@gmail.com>
Signed-off-by: Andre van de Ven <113951599+andrevandeven@users.noreply.github.com>
Signed-off-by: Andre van de Ven <andrevdv@amazon.com>
Co-authored-by: Andre van de Ven <andrevdv@amazon.com>

* IllegalArgumentException when scroll ID has a node no longer part of the Cluster (opensearch-project#19031)



---------

Signed-off-by: Anurag Rai <anurag.rai@uber.com>
Signed-off-by: Anurag Rai <91844619+anuragrai16@users.noreply.github.com>

* Add Changelog entry

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Add secondary constructor

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Modify changelog

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Update changelog

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Add another constructor to fix breaking change check

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

---------

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>
Signed-off-by: Atri Sharma <atri.jiit@gmail.com>
Signed-off-by: Andrew Ross <andrross@amazon.com>
Signed-off-by: Craig Perkins <cwperx@amazon.com>
Signed-off-by: Andre van de Ven <andrebvandeven@gmail.com>
Signed-off-by: Andre van de Ven <113951599+andrevandeven@users.noreply.github.com>
Signed-off-by: Andre van de Ven <andrevdv@amazon.com>
Signed-off-by: Anurag Rai <anurag.rai@uber.com>
Signed-off-by: Anurag Rai <91844619+anuragrai16@users.noreply.github.com>
Co-authored-by: Rajat Gupta <gptrajat@amazon.com>
Co-authored-by: Atri Sharma <atri.jiit@gmail.com>
Co-authored-by: Andrew Ross <andrross@amazon.com>
Co-authored-by: Craig Perkins <cwperx@amazon.com>
Co-authored-by: Andre van de Ven <113951599+andrevandeven@users.noreply.github.com>
Co-authored-by: Andre van de Ven <andrevdv@amazon.com>
Co-authored-by: Anurag Rai <91844619+anuragrai16@users.noreply.github.com>
jainankitk pushed a commit to jainankitk/OpenSearch that referenced this pull request Sep 22, 2025
* Add overload for channelFactory

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Fix tests

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Add Changelog entry

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Fix conflicts

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* When update operations fail during preparation (e.g., version conflicts), (opensearch-project#18917)

TransportShardBulkAction still triggers refresh even though no actual
  writes occurred. This fix checks if locationToSync is null (indicating
  no writes) and prevents refresh in such cases.

  Fixes opensearch-project#15261

Signed-off-by: Atri Sharma <atri.jiit@gmail.com>

* Remove all entries from changelog to be released in 3.2 (opensearch-project#18989)

Signed-off-by: Andrew Ross <andrross@amazon.com>

* Add temporal routing processors for time-based document routing (opensearch-project#18966)

Implements TemporalRoutingProcessor for ingest pipelines and
TemporalRoutingSearchProcessor for search pipelines based on RFC opensearch-project#18920.

 Features:
 - Route documents to shards based on timestamp fields
 - Support hour, day, week, and month granularities
 - Optional hash bucketing for better distribution
 - Automatic search routing to relevant time ranges
 - ISO week format support

The processors enable efficient time-based data organization for
log and metrics workloads by co-locating documents from the same
time period on the same shards.

---------

Signed-off-by: Atri Sharma <atri.jiit@gmail.com>

* Add CompletionStage variants to methods in the Client Interface and default to ActionListener impl (opensearch-project#18998)

* Add CompletableFuture variables to methods in the Client Interface and default to ActionListener impl

Signed-off-by: Craig Perkins <cwperx@amazon.com>

* Add to CHANGELOG

Signed-off-by: Craig Perkins <cwperx@amazon.com>

* Fix typo in CHANGELOG

Signed-off-by: Craig Perkins <cwperx@amazon.com>

* Switch to CompletionStage

Signed-off-by: Craig Perkins <cwperx@amazon.com>

* Update CHANGELOG entry

Signed-off-by: Craig Perkins <cwperx@amazon.com>

---------

Signed-off-by: Craig Perkins <cwperx@amazon.com>

* Expand fetch phase profiling to support inner hits and top hits aggregation phases (opensearch-project#18936)


---------

Signed-off-by: Andre van de Ven <andrebvandeven@gmail.com>
Signed-off-by: Andre van de Ven <113951599+andrevandeven@users.noreply.github.com>
Signed-off-by: Andre van de Ven <andrevdv@amazon.com>
Co-authored-by: Andre van de Ven <andrevdv@amazon.com>

* IllegalArgumentException when scroll ID has a node no longer part of the Cluster (opensearch-project#19031)



---------

Signed-off-by: Anurag Rai <anurag.rai@uber.com>
Signed-off-by: Anurag Rai <91844619+anuragrai16@users.noreply.github.com>

* Add Changelog entry

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Add secondary constructor

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Modify changelog

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Update changelog

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Add another constructor to fix breaking change check

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

---------

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>
Signed-off-by: Atri Sharma <atri.jiit@gmail.com>
Signed-off-by: Andrew Ross <andrross@amazon.com>
Signed-off-by: Craig Perkins <cwperx@amazon.com>
Signed-off-by: Andre van de Ven <andrebvandeven@gmail.com>
Signed-off-by: Andre van de Ven <113951599+andrevandeven@users.noreply.github.com>
Signed-off-by: Andre van de Ven <andrevdv@amazon.com>
Signed-off-by: Anurag Rai <anurag.rai@uber.com>
Signed-off-by: Anurag Rai <91844619+anuragrai16@users.noreply.github.com>
Co-authored-by: Rajat Gupta <gptrajat@amazon.com>
Co-authored-by: Atri Sharma <atri.jiit@gmail.com>
Co-authored-by: Andrew Ross <andrross@amazon.com>
Co-authored-by: Craig Perkins <cwperx@amazon.com>
Co-authored-by: Andre van de Ven <113951599+andrevandeven@users.noreply.github.com>
Co-authored-by: Andre van de Ven <andrevdv@amazon.com>
Co-authored-by: Anurag Rai <91844619+anuragrai16@users.noreply.github.com>
jainankitk pushed a commit to jainankitk/OpenSearch that referenced this pull request Sep 22, 2025
* Add overload for channelFactory

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Fix tests

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Add Changelog entry

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Fix conflicts

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* When update operations fail during preparation (e.g., version conflicts), (opensearch-project#18917)

TransportShardBulkAction still triggers refresh even though no actual
  writes occurred. This fix checks if locationToSync is null (indicating
  no writes) and prevents refresh in such cases.

  Fixes opensearch-project#15261

Signed-off-by: Atri Sharma <atri.jiit@gmail.com>

* Remove all entries from changelog to be released in 3.2 (opensearch-project#18989)

Signed-off-by: Andrew Ross <andrross@amazon.com>

* Add temporal routing processors for time-based document routing (opensearch-project#18966)

Implements TemporalRoutingProcessor for ingest pipelines and
TemporalRoutingSearchProcessor for search pipelines based on RFC opensearch-project#18920.

 Features:
 - Route documents to shards based on timestamp fields
 - Support hour, day, week, and month granularities
 - Optional hash bucketing for better distribution
 - Automatic search routing to relevant time ranges
 - ISO week format support

The processors enable efficient time-based data organization for
log and metrics workloads by co-locating documents from the same
time period on the same shards.

---------

Signed-off-by: Atri Sharma <atri.jiit@gmail.com>

* Add CompletionStage variants to methods in the Client Interface and default to ActionListener impl (opensearch-project#18998)

* Add CompletableFuture variables to methods in the Client Interface and default to ActionListener impl

Signed-off-by: Craig Perkins <cwperx@amazon.com>

* Add to CHANGELOG

Signed-off-by: Craig Perkins <cwperx@amazon.com>

* Fix typo in CHANGELOG

Signed-off-by: Craig Perkins <cwperx@amazon.com>

* Switch to CompletionStage

Signed-off-by: Craig Perkins <cwperx@amazon.com>

* Update CHANGELOG entry

Signed-off-by: Craig Perkins <cwperx@amazon.com>

---------

Signed-off-by: Craig Perkins <cwperx@amazon.com>

* Expand fetch phase profiling to support inner hits and top hits aggregation phases (opensearch-project#18936)

---------

Signed-off-by: Andre van de Ven <andrebvandeven@gmail.com>
Signed-off-by: Andre van de Ven <113951599+andrevandeven@users.noreply.github.com>
Signed-off-by: Andre van de Ven <andrevdv@amazon.com>
Co-authored-by: Andre van de Ven <andrevdv@amazon.com>

* IllegalArgumentException when scroll ID has a node no longer part of the Cluster (opensearch-project#19031)

---------

Signed-off-by: Anurag Rai <anurag.rai@uber.com>
Signed-off-by: Anurag Rai <91844619+anuragrai16@users.noreply.github.com>

* Add Changelog entry

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Add secondary constructor

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Modify changelog

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Update changelog

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Add another constructor to fix breaking change check

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

---------

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>
Signed-off-by: Atri Sharma <atri.jiit@gmail.com>
Signed-off-by: Andrew Ross <andrross@amazon.com>
Signed-off-by: Craig Perkins <cwperx@amazon.com>
Signed-off-by: Andre van de Ven <andrebvandeven@gmail.com>
Signed-off-by: Andre van de Ven <113951599+andrevandeven@users.noreply.github.com>
Signed-off-by: Andre van de Ven <andrevdv@amazon.com>
Signed-off-by: Anurag Rai <anurag.rai@uber.com>
Signed-off-by: Anurag Rai <91844619+anuragrai16@users.noreply.github.com>
Co-authored-by: Rajat Gupta <gptrajat@amazon.com>
Co-authored-by: Atri Sharma <atri.jiit@gmail.com>
Co-authored-by: Andrew Ross <andrross@amazon.com>
Co-authored-by: Craig Perkins <cwperx@amazon.com>
Co-authored-by: Andre van de Ven <113951599+andrevandeven@users.noreply.github.com>
Co-authored-by: Andre van de Ven <andrevdv@amazon.com>
Co-authored-by: Anurag Rai <91844619+anuragrai16@users.noreply.github.com>
Signed-off-by: Ankit Jain <jainankitk@apache.org>
jainankitk pushed a commit to jainankitk/OpenSearch that referenced this pull request Sep 22, 2025
* Add overload for channelFactory

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Fix tests

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Add Changelog entry

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Fix conflicts

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* When update operations fail during preparation (e.g., version conflicts), (opensearch-project#18917)

TransportShardBulkAction still triggers refresh even though no actual
  writes occurred. This fix checks if locationToSync is null (indicating
  no writes) and prevents refresh in such cases.

  Fixes opensearch-project#15261

Signed-off-by: Atri Sharma <atri.jiit@gmail.com>

* Remove all entries from changelog to be released in 3.2 (opensearch-project#18989)

Signed-off-by: Andrew Ross <andrross@amazon.com>

* Add temporal routing processors for time-based document routing (opensearch-project#18966)

Implements TemporalRoutingProcessor for ingest pipelines and
TemporalRoutingSearchProcessor for search pipelines based on RFC opensearch-project#18920.

 Features:
 - Route documents to shards based on timestamp fields
 - Support hour, day, week, and month granularities
 - Optional hash bucketing for better distribution
 - Automatic search routing to relevant time ranges
 - ISO week format support

The processors enable efficient time-based data organization for
log and metrics workloads by co-locating documents from the same
time period on the same shards.

---------

Signed-off-by: Atri Sharma <atri.jiit@gmail.com>

* Add CompletionStage variants to methods in the Client Interface and default to ActionListener impl (opensearch-project#18998)

* Add CompletableFuture variables to methods in the Client Interface and default to ActionListener impl

Signed-off-by: Craig Perkins <cwperx@amazon.com>

* Add to CHANGELOG

Signed-off-by: Craig Perkins <cwperx@amazon.com>

* Fix typo in CHANGELOG

Signed-off-by: Craig Perkins <cwperx@amazon.com>

* Switch to CompletionStage

Signed-off-by: Craig Perkins <cwperx@amazon.com>

* Update CHANGELOG entry

Signed-off-by: Craig Perkins <cwperx@amazon.com>

---------

Signed-off-by: Craig Perkins <cwperx@amazon.com>

* Expand fetch phase profiling to support inner hits and top hits aggregation phases (opensearch-project#18936)

---------

Signed-off-by: Andre van de Ven <andrebvandeven@gmail.com>
Signed-off-by: Andre van de Ven <113951599+andrevandeven@users.noreply.github.com>
Signed-off-by: Andre van de Ven <andrevdv@amazon.com>
Co-authored-by: Andre van de Ven <andrevdv@amazon.com>

* IllegalArgumentException when scroll ID has a node no longer part of the Cluster (opensearch-project#19031)

---------

Signed-off-by: Anurag Rai <anurag.rai@uber.com>
Signed-off-by: Anurag Rai <91844619+anuragrai16@users.noreply.github.com>

* Add Changelog entry

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Add secondary constructor

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Modify changelog

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Update changelog

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Add another constructor to fix breaking change check

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

---------

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>
Signed-off-by: Atri Sharma <atri.jiit@gmail.com>
Signed-off-by: Andrew Ross <andrross@amazon.com>
Signed-off-by: Craig Perkins <cwperx@amazon.com>
Signed-off-by: Andre van de Ven <andrebvandeven@gmail.com>
Signed-off-by: Andre van de Ven <113951599+andrevandeven@users.noreply.github.com>
Signed-off-by: Andre van de Ven <andrevdv@amazon.com>
Signed-off-by: Anurag Rai <anurag.rai@uber.com>
Signed-off-by: Anurag Rai <91844619+anuragrai16@users.noreply.github.com>
Co-authored-by: Rajat Gupta <gptrajat@amazon.com>
Co-authored-by: Atri Sharma <atri.jiit@gmail.com>
Co-authored-by: Andrew Ross <andrross@amazon.com>
Co-authored-by: Craig Perkins <cwperx@amazon.com>
Co-authored-by: Andre van de Ven <113951599+andrevandeven@users.noreply.github.com>
Co-authored-by: Andre van de Ven <andrevdv@amazon.com>
Co-authored-by: Anurag Rai <91844619+anuragrai16@users.noreply.github.com>
Signed-off-by: Ankit Jain <jainankitk@apache.org>
asimmahmood1 pushed a commit to jainankitk/OpenSearch that referenced this pull request Sep 23, 2025
* Add overload for channelFactory

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Fix tests

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Add Changelog entry

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Fix conflicts

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* When update operations fail during preparation (e.g., version conflicts), (opensearch-project#18917)

TransportShardBulkAction still triggers refresh even though no actual
  writes occurred. This fix checks if locationToSync is null (indicating
  no writes) and prevents refresh in such cases.

  Fixes opensearch-project#15261

Signed-off-by: Atri Sharma <atri.jiit@gmail.com>

* Remove all entries from changelog to be released in 3.2 (opensearch-project#18989)

Signed-off-by: Andrew Ross <andrross@amazon.com>

* Add temporal routing processors for time-based document routing (opensearch-project#18966)

Implements TemporalRoutingProcessor for ingest pipelines and
TemporalRoutingSearchProcessor for search pipelines based on RFC opensearch-project#18920.

 Features:
 - Route documents to shards based on timestamp fields
 - Support hour, day, week, and month granularities
 - Optional hash bucketing for better distribution
 - Automatic search routing to relevant time ranges
 - ISO week format support

The processors enable efficient time-based data organization for
log and metrics workloads by co-locating documents from the same
time period on the same shards.

---------

Signed-off-by: Atri Sharma <atri.jiit@gmail.com>

* Add CompletionStage variants to methods in the Client Interface and default to ActionListener impl (opensearch-project#18998)

* Add CompletableFuture variables to methods in the Client Interface and default to ActionListener impl

Signed-off-by: Craig Perkins <cwperx@amazon.com>

* Add to CHANGELOG

Signed-off-by: Craig Perkins <cwperx@amazon.com>

* Fix typo in CHANGELOG

Signed-off-by: Craig Perkins <cwperx@amazon.com>

* Switch to CompletionStage

Signed-off-by: Craig Perkins <cwperx@amazon.com>

* Update CHANGELOG entry

Signed-off-by: Craig Perkins <cwperx@amazon.com>

---------

Signed-off-by: Craig Perkins <cwperx@amazon.com>

* Expand fetch phase profiling to support inner hits and top hits aggregation phases (opensearch-project#18936)


---------

Signed-off-by: Andre van de Ven <andrebvandeven@gmail.com>
Signed-off-by: Andre van de Ven <113951599+andrevandeven@users.noreply.github.com>
Signed-off-by: Andre van de Ven <andrevdv@amazon.com>
Co-authored-by: Andre van de Ven <andrevdv@amazon.com>

* IllegalArgumentException when scroll ID has a node no longer part of the Cluster (opensearch-project#19031)



---------

Signed-off-by: Anurag Rai <anurag.rai@uber.com>
Signed-off-by: Anurag Rai <91844619+anuragrai16@users.noreply.github.com>

* Add Changelog entry

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Add secondary constructor

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Modify changelog

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Update changelog

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Add another constructor to fix breaking change check

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

---------

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>
Signed-off-by: Atri Sharma <atri.jiit@gmail.com>
Signed-off-by: Andrew Ross <andrross@amazon.com>
Signed-off-by: Craig Perkins <cwperx@amazon.com>
Signed-off-by: Andre van de Ven <andrebvandeven@gmail.com>
Signed-off-by: Andre van de Ven <113951599+andrevandeven@users.noreply.github.com>
Signed-off-by: Andre van de Ven <andrevdv@amazon.com>
Signed-off-by: Anurag Rai <anurag.rai@uber.com>
Signed-off-by: Anurag Rai <91844619+anuragrai16@users.noreply.github.com>
Co-authored-by: Rajat Gupta <gptrajat@amazon.com>
Co-authored-by: Atri Sharma <atri.jiit@gmail.com>
Co-authored-by: Andrew Ross <andrross@amazon.com>
Co-authored-by: Craig Perkins <cwperx@amazon.com>
Co-authored-by: Andre van de Ven <113951599+andrevandeven@users.noreply.github.com>
Co-authored-by: Andre van de Ven <andrevdv@amazon.com>
Co-authored-by: Anurag Rai <91844619+anuragrai16@users.noreply.github.com>
vinaykpud pushed a commit to vinaykpud/OpenSearch that referenced this pull request Sep 26, 2025
* Add overload for channelFactory

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Fix tests

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Add Changelog entry

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Fix conflicts

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* When update operations fail during preparation (e.g., version conflicts), (opensearch-project#18917)

TransportShardBulkAction still triggers refresh even though no actual
  writes occurred. This fix checks if locationToSync is null (indicating
  no writes) and prevents refresh in such cases.

  Fixes opensearch-project#15261

Signed-off-by: Atri Sharma <atri.jiit@gmail.com>

* Remove all entries from changelog to be released in 3.2 (opensearch-project#18989)

Signed-off-by: Andrew Ross <andrross@amazon.com>

* Add temporal routing processors for time-based document routing (opensearch-project#18966)

Implements TemporalRoutingProcessor for ingest pipelines and
TemporalRoutingSearchProcessor for search pipelines based on RFC opensearch-project#18920.

 Features:
 - Route documents to shards based on timestamp fields
 - Support hour, day, week, and month granularities
 - Optional hash bucketing for better distribution
 - Automatic search routing to relevant time ranges
 - ISO week format support

The processors enable efficient time-based data organization for
log and metrics workloads by co-locating documents from the same
time period on the same shards.

---------

Signed-off-by: Atri Sharma <atri.jiit@gmail.com>

* Add CompletionStage variants to methods in the Client Interface and default to ActionListener impl (opensearch-project#18998)

* Add CompletableFuture variables to methods in the Client Interface and default to ActionListener impl

Signed-off-by: Craig Perkins <cwperx@amazon.com>

* Add to CHANGELOG

Signed-off-by: Craig Perkins <cwperx@amazon.com>

* Fix typo in CHANGELOG

Signed-off-by: Craig Perkins <cwperx@amazon.com>

* Switch to CompletionStage

Signed-off-by: Craig Perkins <cwperx@amazon.com>

* Update CHANGELOG entry

Signed-off-by: Craig Perkins <cwperx@amazon.com>

---------

Signed-off-by: Craig Perkins <cwperx@amazon.com>

* Expand fetch phase profiling to support inner hits and top hits aggregation phases (opensearch-project#18936)


---------

Signed-off-by: Andre van de Ven <andrebvandeven@gmail.com>
Signed-off-by: Andre van de Ven <113951599+andrevandeven@users.noreply.github.com>
Signed-off-by: Andre van de Ven <andrevdv@amazon.com>
Co-authored-by: Andre van de Ven <andrevdv@amazon.com>

* IllegalArgumentException when scroll ID has a node no longer part of the Cluster (opensearch-project#19031)



---------

Signed-off-by: Anurag Rai <anurag.rai@uber.com>
Signed-off-by: Anurag Rai <91844619+anuragrai16@users.noreply.github.com>

* Add Changelog entry

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Add secondary constructor

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Modify changelog

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Update changelog

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

* Add another constructor to fix breaking change check

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>

---------

Signed-off-by: Rajat Gupta <gptrajat@amazon.com>
Signed-off-by: Atri Sharma <atri.jiit@gmail.com>
Signed-off-by: Andrew Ross <andrross@amazon.com>
Signed-off-by: Craig Perkins <cwperx@amazon.com>
Signed-off-by: Andre van de Ven <andrebvandeven@gmail.com>
Signed-off-by: Andre van de Ven <113951599+andrevandeven@users.noreply.github.com>
Signed-off-by: Andre van de Ven <andrevdv@amazon.com>
Signed-off-by: Anurag Rai <anurag.rai@uber.com>
Signed-off-by: Anurag Rai <91844619+anuragrai16@users.noreply.github.com>
Co-authored-by: Rajat Gupta <gptrajat@amazon.com>
Co-authored-by: Atri Sharma <atri.jiit@gmail.com>
Co-authored-by: Andrew Ross <andrross@amazon.com>
Co-authored-by: Craig Perkins <cwperx@amazon.com>
Co-authored-by: Andre van de Ven <113951599+andrevandeven@users.noreply.github.com>
Co-authored-by: Andre van de Ven <andrevdv@amazon.com>
Co-authored-by: Anurag Rai <91844619+anuragrai16@users.noreply.github.com>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

6 participants