From 7dd4199f86e9c88f9d9223fd04b5124536ded142 Mon Sep 17 00:00:00 2001 From: wu-sheng Date: Thu, 7 Dec 2017 09:44:08 +0800 Subject: [PATCH] Restore the auto deleting feature for 5.0 preview test. --- .../apm/collector/storage/es/DataTTLKeeperTimer.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/apm-collector/apm-collector-storage/collector-storage-es-provider/src/main/java/org/skywalking/apm/collector/storage/es/DataTTLKeeperTimer.java b/apm-collector/apm-collector-storage/collector-storage-es-provider/src/main/java/org/skywalking/apm/collector/storage/es/DataTTLKeeperTimer.java index f614bbef9..f33f65290 100644 --- a/apm-collector/apm-collector-storage/collector-storage-es-provider/src/main/java/org/skywalking/apm/collector/storage/es/DataTTLKeeperTimer.java +++ b/apm-collector/apm-collector-storage/collector-storage-es-provider/src/main/java/org/skywalking/apm/collector/storage/es/DataTTLKeeperTimer.java @@ -19,6 +19,8 @@ package org.skywalking.apm.collector.storage.es; import java.util.Calendar; +import java.util.concurrent.Executors; +import java.util.concurrent.TimeUnit; import org.skywalking.apm.collector.core.module.ModuleManager; import org.skywalking.apm.collector.storage.StorageModule; import org.skywalking.apm.collector.storage.dao.ICpuMetricPersistenceDAO; @@ -53,8 +55,7 @@ public class DataTTLKeeperTimer { } public void start() { - //TODO: Don't release auto delete feature, yet - //Executors.newSingleThreadScheduledExecutor().scheduleAtFixedRate(this::delete, 1, 8, TimeUnit.HOURS); + Executors.newSingleThreadScheduledExecutor().scheduleAtFixedRate(this::delete, 1, 8, TimeUnit.HOURS); } private void delete() {