fix compile error after merge
This commit is contained in:
parent
10c60fae93
commit
75cae4560c
|
@ -6,6 +6,7 @@
|
||||||
package org.elasticsearch.xpack.indexlifecycle;
|
package org.elasticsearch.xpack.indexlifecycle;
|
||||||
|
|
||||||
import com.carrotsearch.hppc.cursors.ObjectCursor;
|
import com.carrotsearch.hppc.cursors.ObjectCursor;
|
||||||
|
|
||||||
import org.apache.logging.log4j.Logger;
|
import org.apache.logging.log4j.Logger;
|
||||||
import org.apache.lucene.util.SetOnce;
|
import org.apache.lucene.util.SetOnce;
|
||||||
import org.elasticsearch.client.Client;
|
import org.elasticsearch.client.Client;
|
||||||
|
@ -101,7 +102,7 @@ public class IndexLifecycleService extends AbstractComponent
|
||||||
boolean pollIntervalSettingChanged = !pollInterval.equals(previousPollInterval);
|
boolean pollIntervalSettingChanged = !pollInterval.equals(previousPollInterval);
|
||||||
|
|
||||||
if (scheduler.get() == null) { // metadata installed and scheduler should be kicked off. start your engines.
|
if (scheduler.get() == null) { // metadata installed and scheduler should be kicked off. start your engines.
|
||||||
scheduler.set(new SchedulerEngine(clock));
|
scheduler.set(new SchedulerEngine(settings, clock));
|
||||||
scheduler.get().register(this);
|
scheduler.get().register(this);
|
||||||
scheduleJob(pollInterval);
|
scheduleJob(pollInterval);
|
||||||
} else if (scheduledJob == null) {
|
} else if (scheduledJob == null) {
|
||||||
|
|
Loading…
Reference in New Issue