@@ -574,8 +574,7 @@ ShardFollowNodeTask createShardFollowTask(int maxBatchOperationCount, int maxCon
574
574
AtomicBoolean stopped = new AtomicBoolean (false );
575
575
ShardFollowTask params = new ShardFollowTask (null , new ShardId ("follow_index" , "" , 0 ),
576
576
new ShardId ("leader_index" , "" , 0 ), maxBatchOperationCount , maxConcurrentReadBatches , maxBatchSizeInBytes ,
577
- maxConcurrentWriteBatches , bufferWriteLimit , TimeValue .timeValueMillis (500 ), TimeValue .timeValueMillis (10 ),
578
- Collections .emptyMap ());
577
+ maxConcurrentWriteBatches , bufferWriteLimit , TimeValue .ZERO , TimeValue .ZERO , Collections .emptyMap ());
579
578
580
579
shardChangesRequests = new ArrayList <>();
581
580
bulkShardOperationRequests = new ArrayList <>();
@@ -584,8 +583,7 @@ ShardFollowNodeTask createShardFollowTask(int maxBatchOperationCount, int maxCon
584
583
mappingUpdateFailures = new LinkedList <>();
585
584
imdVersions = new LinkedList <>();
586
585
followerGlobalCheckpoints = new LinkedList <>();
587
- return new ShardFollowNodeTask (1L , "type" , ShardFollowTask .NAME , "description" , null , Collections .emptyMap (),
588
- params , scheduler , TimeValue .ZERO , TimeValue .ZERO ) {
586
+ return new ShardFollowNodeTask (1L , "type" , ShardFollowTask .NAME , "description" , null , Collections .emptyMap (), params , scheduler ) {
589
587
590
588
@ Override
591
589
protected void innerUpdateMapping (LongConsumer handler , Consumer <Exception > errorHandler ) {
0 commit comments