diff --git a/x-pack/plugins/monitoring/server/kibana_monitoring/bulk_uploader.js b/x-pack/plugins/monitoring/server/kibana_monitoring/bulk_uploader.js index 5d7c2f3f5d8b..b66617c6e590 100644 --- a/x-pack/plugins/monitoring/server/kibana_monitoring/bulk_uploader.js +++ b/x-pack/plugins/monitoring/server/kibana_monitoring/bulk_uploader.js @@ -66,7 +66,13 @@ export class BulkUploader { // this is internal bulk upload, so filter out API-only collectors const filterThem = _collectorSet => _collectorSet.getFilteredCollectorSet(c => c.ignoreForInternalUploader !== true); - this._fetchAndUpload(filterThem(collectorSet)); // initial fetch + + if (this._timer) { + clearInterval(this._timer); + } else { + this._fetchAndUpload(filterThem(collectorSet)); // initial fetch + } + this._timer = setInterval(() => { this._fetchAndUpload(filterThem(collectorSet)); }, this._interval);