We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 46ca835 commit 0cf9051Copy full SHA for 0cf9051
1 file changed
server/src/main/java/org/opensearch/index/shard/IndexShard.java
@@ -399,6 +399,8 @@ Runnable getGlobalCheckpointSyncer() {
399
private final ReferencedSegmentsPublisher referencedSegmentsPublisher;
400
private final Set<MergedSegmentCheckpoint> pendingMergedSegmentCheckpoints = Sets.newConcurrentHashSet();
401
private final MergedSegmentTransferTracker mergedSegmentTransferTracker;
402
+
403
+ // Used to limit the number of concurrent translog tasks. When the semaphore is exhausted, serial recovery is used.
404
private static final Semaphore translogConcurrentRecoverySemaphore = new Semaphore(1000);
405
406
@InternalApi
0 commit comments