File tree Expand file tree Collapse file tree 1 file changed +4
-0
lines changed 
server/src/internalClusterTest/java/org/elasticsearch/action/bulk Expand file tree Collapse file tree 1 file changed +4
-0
lines changed Original file line number Diff line number Diff line change @@ -188,6 +188,7 @@ public void testIncrementalBulkLowWatermarkBackOff() throws Exception {
188188        assertFalse (refCounted .hasReferences ());
189189    }
190190
191+     @ AwaitsFix (bugUrl  = "depends on being able to block the write coordination pool" )
191192    public  void  testIncrementalBulkHighWatermarkBackOff () throws  Exception  {
192193        String  index  = "test" ;
193194        createIndex (index );
@@ -283,6 +284,7 @@ public void testMultipleBulkPartsWithBackoff() {
283284        }
284285    }
285286
287+     @ AwaitsFix (bugUrl  = "depends on being able to block the write coordination pool" )
286288    public  void  testGlobalBulkFailure () throws  InterruptedException  {
287289        ExecutorService  executorService  = Executors .newFixedThreadPool (1 );
288290        CountDownLatch  blockingLatch  = new  CountDownLatch (1 );
@@ -314,6 +316,7 @@ public void testGlobalBulkFailure() throws InterruptedException {
314316        }
315317    }
316318
319+     @ AwaitsFix (bugUrl  = "depends on being able to block the write coordination pool" )
317320    public  void  testBulkLevelBulkFailureAfterFirstIncrementalRequest () throws  Exception  {
318321        ExecutorService  executorService  = Executors .newFixedThreadPool (1 );
319322
@@ -558,6 +561,7 @@ public boolean isForceExecution() {
558561    }
559562
560563    private  static  void  fillWriteCoordinationQueue (ThreadPool  threadPool ) {
564+         assumeTrue ("Can't fill the queue" , false );
561565        final  var  queueSize  = Math .toIntExact (threadPool .info (ThreadPool .Names .WRITE_COORDINATION ).getQueueSize ().singles ());
562566        final  var  queueFilled  = new  AtomicBoolean (false );
563567        final  var  queueFillingTask  = new  AbstractRunnable () {
    
 
   
 
     
   
   
          
     
  
    
     
 
    
      
     
 
     
    You can’t perform that action at this time.
  
 
    
  
     
    
      
        
     
 
       
      
     
   
 
    
    
  
 
  
 
     
    
0 commit comments