honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

[ML-DataFrame] increase the scheduler interval to 10s (#42845) 

increases the scheduler interval to fire less frequently, namely changing it from 1s to 10s. The scheduler interval is used for retrying after an error condition.
This commit is contained in:
Hendrik Muhs 2019-06-06 07:43:36 +02:00
parent 6eb4600e93
commit 5cd503a1e0
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
x-pack/plugin/data-frame/src/main/java/org/elasticsearch/xpack/dataframe/transforms/DataFrameTransformTask.java
View File

@ -53,6 +53,8 @@ import java.util.concurrent.atomic.AtomicReference;
public class DataFrameTransformTask extends AllocatedPersistentTask implements SchedulerEngine.Listener {
// interval the scheduler sends an event
private static final int SCHEDULER_NEXT_MILLISECONDS = 10000;
private static final Logger logger = LogManager.getLogger(DataFrameTransformTask.class);
// TODO consider moving to dynamic cluster setting
private static final int MAX_CONTINUOUS_FAILURES = 10;
@ -337,7 +339,7 @@ public class DataFrameTransformTask extends AllocatedPersistentTask implements S
private SchedulerEngine.Schedule next() {
return (startTime, now) -> {
return now + 1000; // to be fixed, hardcode something
return now + SCHEDULER_NEXT_MILLISECONDS;
};
}