File tree Expand file tree Collapse file tree 2 files changed +3
-5
lines changed
server/src/main/java/org/elasticsearch Expand file tree Collapse file tree 2 files changed +3
-5
lines changed Original file line number Diff line number Diff line change 1111
1212import org .apache .logging .log4j .LogManager ;
1313import org .apache .logging .log4j .Logger ;
14- import org .elasticsearch .cluster .ClusterChangedEvent ;
15- import org .elasticsearch .cluster .ClusterStateListener ;
1614import org .elasticsearch .common .ExponentiallyWeightedMovingAverage ;
1715import org .elasticsearch .core .Tuple ;
18- import org .elasticsearch .index .Index ;
1916
2017import java .util .concurrent .BlockingQueue ;
2118import java .util .concurrent .ConcurrentHashMap ;
Original file line number Diff line number Diff line change @@ -707,7 +707,8 @@ private void construct(
707707
708708 // TODO DR - this is a bit of a hack to get the cluster service into the plugins
709709 var executor = (TaskExecutionTimeTrackingEsThreadPoolExecutor ) threadPool .executor (ThreadPool .Names .SEARCH );
710- TaskExecutionTimeTrackingPerIndexEsThreadPoolExecutor perIndexEsThreadPoolExecutor = (TaskExecutionTimeTrackingPerIndexEsThreadPoolExecutor ) executor ;
710+ TaskExecutionTimeTrackingPerIndexEsThreadPoolExecutor perIndexEsThreadPoolExecutor =
711+ (TaskExecutionTimeTrackingPerIndexEsThreadPoolExecutor ) executor ;
711712 searchLoadMetricsReporter (perIndexEsThreadPoolExecutor );
712713 clusterService .addListener (new SearchIndexTimeTrackingCleanupService (perIndexEsThreadPoolExecutor ));
713714
@@ -1269,7 +1270,7 @@ private void searchLoadMetricsReporter(TaskExecutionTimeTrackingPerIndexEsThread
12691270 TimerTask task = new TimerTask () {
12701271 @ Override
12711272 public void run () {
1272- if (executor .indexExecutionTime .size () > 0 ) {
1273+ if (executor .indexExecutionTime .size () > 0 ) {
12731274 logger .info ("Number of reported indices: {}" , executor .indexExecutionTime .size ());
12741275 logger .info ("Number of runnables: {}" , executor .runnableToIndexName .size ());
12751276 executor .indexExecutionTime .forEach ((index , tuple ) -> {
You can’t perform that action at this time.
0 commit comments