METRON-1649 Intermittent Test Failure ProfileBuilderBoltTest#testFlushExpiredProfiles (nickwallen) closes apache/metron#1090
Project: http://git-wip-us.apache.org/repos/asf/metron/repo Commit: http://git-wip-us.apache.org/repos/asf/metron/commit/d90f7cfd Tree: http://git-wip-us.apache.org/repos/asf/metron/tree/d90f7cfd Diff: http://git-wip-us.apache.org/repos/asf/metron/diff/d90f7cfd Branch: refs/heads/feature/METRON-1554-pcap-query-panel Commit: d90f7cfdedd3435bfc4c081600e4dbca052aef21 Parents: 93276f8 Author: nickwallen <[email protected]> Authored: Tue Jul 3 10:40:20 2018 -0400 Committer: nickallen <[email protected]> Committed: Tue Jul 3 10:40:20 2018 -0400 ---------------------------------------------------------------------- .../java/org/apache/metron/profiler/bolt/ProfileBuilderBolt.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/metron/blob/d90f7cfd/metron-analytics/metron-profiler/src/main/java/org/apache/metron/profiler/bolt/ProfileBuilderBolt.java ---------------------------------------------------------------------- diff --git a/metron-analytics/metron-profiler/src/main/java/org/apache/metron/profiler/bolt/ProfileBuilderBolt.java b/metron-analytics/metron-profiler/src/main/java/org/apache/metron/profiler/bolt/ProfileBuilderBolt.java index ca02b58..0d1f27e 100644 --- a/metron-analytics/metron-profiler/src/main/java/org/apache/metron/profiler/bolt/ProfileBuilderBolt.java +++ b/metron-analytics/metron-profiler/src/main/java/org/apache/metron/profiler/bolt/ProfileBuilderBolt.java @@ -423,8 +423,10 @@ public class ProfileBuilderBolt extends BaseWindowedBolt implements Reloadable { */ private void startFlushingExpiredProfiles() { + long initialDelay = profileTimeToLiveMillis; + long period = profileTimeToLiveMillis; flushExpiredExecutor = Executors.newSingleThreadScheduledExecutor(); - flushExpiredExecutor.scheduleAtFixedRate(() -> flushExpired(), 0, profileTimeToLiveMillis, TimeUnit.MILLISECONDS); + flushExpiredExecutor.scheduleAtFixedRate(() -> flushExpired(), initialDelay, period, TimeUnit.MILLISECONDS); } @Override
