Skip to content
Permalink

Comparing changes

This is a direct comparison between two commits made in this repository or its related repositories. View the default comparison for this range or learn more about diff comparisons.

Open a pull request

Create a new pull request by comparing changes across two branches. If you need to, you can also . Learn more about diff comparisons here.
base repository: opensearch-project/OpenSearch
Failed to load repositories. Confirm that selected base ref is valid, then try again.
Loading
base: 3b87a37276edf682ebe1646117381aeeca0a5b46
Choose a base ref
..
head repository: opensearch-project/OpenSearch
Failed to load repositories. Confirm that selected head ref is valid, then try again.
Loading
compare: fa2192ec5f3598c065d1d54e5aabf21ff24a31d3
Choose a head ref
Showing with 2,712 additions and 151 deletions.
  1. +8 −0 CHANGELOG.md
  2. +628 −6 ...nternalClusterTest/java/org/opensearch/cluster/coordination/AwarenessAttributeDecommissionIT.java
  3. +214 −0 ...er/src/internalClusterTest/java/org/opensearch/clustermanager/ClusterManagerTaskThrottlingIT.java
  4. +8 −1 server/src/main/java/org/opensearch/OpenSearchException.java
  5. +4 −0 ...main/java/org/opensearch/action/admin/cluster/decommission/awareness/put/DecommissionRequest.java
  6. +10 −0 server/src/main/java/org/opensearch/action/admin/cluster/reroute/TransportClusterRerouteAction.java
  7. +13 −0 .../main/java/org/opensearch/action/admin/cluster/settings/TransportClusterUpdateSettingsAction.java
  8. +6 −1 ...ain/java/org/opensearch/action/admin/cluster/storedscripts/TransportDeleteStoredScriptAction.java
  9. +6 −1 ...c/main/java/org/opensearch/action/admin/cluster/storedscripts/TransportPutStoredScriptAction.java
  10. +11 −0 server/src/main/java/org/opensearch/action/admin/indices/create/AutoCreateAction.java
  11. +10 −0 .../java/org/opensearch/action/admin/indices/dangling/delete/TransportDeleteDanglingIndexAction.java
  12. +10 −0 server/src/main/java/org/opensearch/action/admin/indices/datastream/DeleteDataStreamAction.java
  13. +10 −0 server/src/main/java/org/opensearch/action/admin/indices/rollover/TransportRolloverAction.java
  14. +126 −0 server/src/main/java/org/opensearch/action/bulk/BackoffPolicy.java
  15. +29 −12 server/src/main/java/org/opensearch/action/support/RetryableAction.java
  16. +49 −6 ...src/main/java/org/opensearch/action/support/clustermanager/TransportClusterManagerNodeAction.java
  17. +11 −0 server/src/main/java/org/opensearch/cluster/ClusterStateTaskExecutor.java
  18. +1 −1 server/src/main/java/org/opensearch/cluster/decommission/DecommissionService.java
  19. +10 −0 server/src/main/java/org/opensearch/cluster/metadata/MetadataCreateDataStreamService.java
  20. +11 −0 server/src/main/java/org/opensearch/cluster/metadata/MetadataCreateIndexService.java
  21. +12 −0 server/src/main/java/org/opensearch/cluster/metadata/MetadataDeleteIndexService.java
  22. +12 −0 server/src/main/java/org/opensearch/cluster/metadata/MetadataIndexAliasesService.java
  23. +52 −0 server/src/main/java/org/opensearch/cluster/metadata/MetadataIndexTemplateService.java
  24. +12 −0 server/src/main/java/org/opensearch/cluster/metadata/MetadataMappingService.java
  25. +11 −0 server/src/main/java/org/opensearch/cluster/metadata/MetadataUpdateSettingsService.java
  26. +49 −0 server/src/main/java/org/opensearch/cluster/service/ClusterManagerTaskKeys.java
  27. +200 −0 server/src/main/java/org/opensearch/cluster/service/ClusterManagerTaskThrottler.java
  28. +16 −0 server/src/main/java/org/opensearch/cluster/service/ClusterManagerTaskThrottlerListener.java
  29. +28 −0 server/src/main/java/org/opensearch/cluster/service/ClusterManagerThrottlingException.java
  30. +42 −0 server/src/main/java/org/opensearch/cluster/service/ClusterManagerThrottlingStats.java
  31. +11 −0 server/src/main/java/org/opensearch/cluster/service/ClusterService.java
  32. +33 −3 server/src/main/java/org/opensearch/cluster/service/MasterService.java
  33. +43 −29 server/src/main/java/org/opensearch/cluster/service/TaskBatcher.java
  34. +41 −0 server/src/main/java/org/opensearch/cluster/service/TaskBatcherListener.java
  35. +2 −0 server/src/main/java/org/opensearch/common/settings/ClusterSettings.java
  36. +18 −1 server/src/main/java/org/opensearch/ingest/IngestService.java
  37. +32 −0 server/src/main/java/org/opensearch/persistent/PersistentTasksClusterService.java
  38. +17 −0 server/src/main/java/org/opensearch/repositories/RepositoriesService.java
  39. +6 −0 server/src/main/java/org/opensearch/repositories/blobstore/BlobStoreRepository.java
  40. +13 −0 server/src/main/java/org/opensearch/script/ScriptService.java
  41. +13 −0 server/src/main/java/org/opensearch/snapshots/RestoreService.java
  42. +35 −1 server/src/main/java/org/opensearch/snapshots/SnapshotsService.java
  43. +2 −0 server/src/test/java/org/opensearch/ExceptionSerializationTests.java
  44. +41 −0 server/src/test/java/org/opensearch/action/bulk/BackoffPolicyTests.java
  45. +102 −0 ...est/java/org/opensearch/action/support/clustermanager/TransportClusterManagerNodeActionTests.java
  46. +2 −1 server/src/test/java/org/opensearch/cluster/metadata/MetadataDeleteIndexServiceTests.java
  47. +2 −1 server/src/test/java/org/opensearch/cluster/metadata/MetadataIndexAliasesServiceTests.java
  48. +2 −27 server/src/test/java/org/opensearch/cluster/metadata/MetadataIndexTemplateServiceTests.java
  49. +366 −0 server/src/test/java/org/opensearch/cluster/service/ClusterManagerTaskThrottlerTests.java
  50. +267 −0 server/src/test/java/org/opensearch/cluster/service/MasterServiceTests.java
  51. +26 −2 server/src/test/java/org/opensearch/cluster/service/TaskBatcherTests.java
  52. +10 −7 server/src/test/java/org/opensearch/persistent/PersistentTasksClusterServiceTests.java
  53. +18 −15 test/framework/src/main/java/org/opensearch/cluster/coordination/MockSinglePrioritizingExecutor.java
  54. +1 −36 ...mework/src/test/java/org/opensearch/cluster/coordination/MockSinglePrioritizingExecutorTests.java
8 changes: 8 additions & 0 deletions CHANGELOG.md
View file
Original file line number Diff line number Diff line change
@@ -54,6 +54,13 @@ Inspired from [Keep a Changelog](https://keepachangelog.com/en/1.0.0/)
- Remote shard balancer support for searchable snapshots ([#4870](https://github.com/opensearch-project/OpenSearch/pull/4870))
- Added search backpressure stats API ([#4932](https://github.com/opensearch-project/OpenSearch/pull/4932))
- [Test] Add IAE test for deprecated edgeNGram analyzer name ([#5040](https://github.com/opensearch-project/OpenSearch/pull/5040))
- Add Cluster manager task throttling framework. Cluster manager node will throttle task submission based on throttling thresholds.
This throttling will be at task type level. Data nodes will perform retries on these throttling exception with exponential delay. (PR: [#4986](https://github.com/opensearch-project/OpenSearch/pull/4986)) ( Issue : [#479](https://github.com/opensearch-project/OpenSearch/issues/479))
- Throttling Exception / New Backoff policy([#3527](https://github.com/opensearch-project/OpenSearch/pull/3527))
- Cluster Manager node side change([#3882](https://github.com/opensearch-project/OpenSearch/pull/3882))
- Data node side change([#4204](https://github.com/opensearch-project/OpenSearch/pull/4204))
- on-boarding of tasks([#4542](https://github.com/opensearch-project/OpenSearch/pull/4542))
- Integs ([4588](https://github.com/opensearch-project/OpenSearch/pull/4588))
- Update to Gradle 7.6 and JDK-19 ([#4973](https://github.com/opensearch-project/OpenSearch/pull/4973))

### Dependencies
@@ -115,6 +122,7 @@ Inspired from [Keep a Changelog](https://keepachangelog.com/en/1.0.0/)
- Update to Apache Lucene 9.4.0 ([#4661](https://github.com/opensearch-project/OpenSearch/pull/4661))
- Controlling discovery for decommissioned nodes ([#4590](https://github.com/opensearch-project/OpenSearch/pull/4590))
- Backport Apache Lucene version change for 2.4.0 ([#4677](https://github.com/opensearch-project/OpenSearch/pull/4677))
- Integ Tests for Awareness Attribute Decommissioning ([#4715](https://github.com/opensearch-project/OpenSearch/pull/4715))
- Use ReplicationFailedException instead of OpensearchException in ReplicationTarget ([#4725](https://github.com/opensearch-project/OpenSearch/pull/4725))
- Fix weighted routing metadata deserialization error on process restart ([#4691](https://github.com/opensearch-project/OpenSearch/pull/4691))
- Refactor Base Action class javadocs to OpenSearch.API ([#4732](https://github.com/opensearch-project/OpenSearch/pull/4732))
Loading