|
36 | 36 | import org.elasticsearch.indices.recovery.PeerRecoveryTargetService; |
37 | 37 | import org.elasticsearch.plugins.Plugin; |
38 | 38 | import org.elasticsearch.test.ESIntegTestCase; |
39 | | -import org.elasticsearch.test.junit.annotations.TestLogging; |
40 | 39 | import org.elasticsearch.test.transport.MockTransportService; |
41 | 40 | import org.elasticsearch.threadpool.ThreadPool; |
42 | 41 | import org.elasticsearch.transport.TransportService; |
@@ -356,7 +355,6 @@ public void testRetentionLeasesBackgroundSyncWithSoftDeletesDisabled() throws Ex |
356 | 355 | assertFalse("retention leases background sync must be a noop if soft deletes is disabled", backgroundSyncRequestSent.get()); |
357 | 356 | } |
358 | 357 |
|
359 | | - @TestLogging(value = "org.elasticsearch.index:debug,org.elasticsearch.indices.recovery:trace") |
360 | 358 | public void testRetentionLeasesSyncOnRecovery() throws Exception { |
361 | 359 | final int numberOfReplicas = 2 - scaledRandomIntBetween(0, 2); |
362 | 360 | internalCluster().ensureAtLeastNumDataNodes(1 + numberOfReplicas); |
@@ -393,7 +391,6 @@ public void testRetentionLeasesSyncOnRecovery() throws Exception { |
393 | 391 | final ActionListener<ReplicationResponse> listener = countDownLatchListener(latch); |
394 | 392 | currentRetentionLeases.put(id, primary.addRetentionLease(id, retainingSequenceNumber, source, listener)); |
395 | 393 | latch.await(); |
396 | | - currentRetentionLeases.put(id, primary.renewRetentionLease(id, retainingSequenceNumber, source)); |
397 | 394 | } |
398 | 395 | logger.info("finished adding [{}] retention leases", length); |
399 | 396 |
|
|
0 commit comments