Skip to content

Commit a033cd1

Browse files
authored
Handling concurrent segment search as part of fetch profiling (#19164)
Signed-off-by: Ankit Jain <[email protected]>
1 parent 3f86407 commit a033cd1

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

server/src/main/java/org/opensearch/search/profile/fetch/FlatFetchProfileTree.java

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -12,11 +12,12 @@
1212
import org.opensearch.search.profile.Timer;
1313

1414
import java.util.ArrayList;
15-
import java.util.HashMap;
1615
import java.util.List;
1716
import java.util.Map;
1817
import java.util.Set;
1918
import java.util.TreeMap;
19+
import java.util.concurrent.ConcurrentHashMap;
20+
import java.util.concurrent.ConcurrentMap;
2021

2122
/**
2223
* Simplified profiling tree for fetch phase operations. Each fetch phase is
@@ -59,8 +60,8 @@ private static class Node {
5960
}
6061

6162
private final List<Node> roots = new ArrayList<>();
62-
private final Map<String, Node> rootsMap = new HashMap<>();
63-
private final Map<String, Node> phaseMap = new HashMap<>();
63+
private final ConcurrentMap<String, Node> rootsMap = new ConcurrentHashMap<>();
64+
private final ConcurrentMap<String, Node> phaseMap = new ConcurrentHashMap<>();
6465

6566
/** Start profiling a new fetch phase and return its breakdown. */
6667
FetchProfileBreakdown startFetchPhase(String element) {

0 commit comments

Comments
 (0)