File tree Expand file tree Collapse file tree 2 files changed +1
-12
lines changed
internalClusterTest/java/org/elasticsearch/recovery
main/java/org/elasticsearch/index/shard Expand file tree Collapse file tree 2 files changed +1
-12
lines changed Original file line number Diff line number Diff line change @@ -203,7 +203,7 @@ public void testSimpleRelocationWithIndexingPaused() throws Exception {
203203 IndexShard shard = indicesService .indexServiceSafe (resolveIndex ("test" )).getShard (0 );
204204 shard .activateThrottling ();
205205 // Verify that indexing is paused for the throttled shard
206- assertThat (shard .isIndexingPaused (), equalTo (true ));
206+ assertThat (shard .getEngineOrNull (). isIndexingPaused (), equalTo (true ));
207207 // Try to index a document into the "test" index which is currently throttled
208208 logger .info ("--> Try to index a doc while indexing is paused" );
209209 IndexRequestBuilder indexRequestBuilder = prepareIndex ("test" ).setId (Integer .toString (20 )).setSource ("field" , "value" + 20 );
Original file line number Diff line number Diff line change @@ -2757,17 +2757,6 @@ public void deactivateThrottling() {
27572757 }
27582758 }
27592759
2760- public boolean isIndexingPaused () {
2761- Engine engine = getEngineOrNull ();
2762- final boolean indexingPaused ;
2763- if (engine == null ) {
2764- indexingPaused = false ;
2765- } else {
2766- indexingPaused = engine .isIndexingPaused ();
2767- }
2768- return (indexingPaused );
2769- }
2770-
27712760 public void suspendThrottling () {
27722761 try {
27732762 getEngine ().suspendThrottling ();
You can’t perform that action at this time.
0 commit comments