You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@metron.apache.org by mm...@apache.org on 2018/07/11 01:33:00 UTC
[44/50] [abbrv] metron git commit: METRON-1649 Intermittent Test
Failure ProfileBuilderBoltTest#testFlushExpiredProfiles (nickwallen) closes
apache/metron#1090
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 <ni...@nickallen.org>
Authored: Tue Jul 3 10:40:20 2018 -0400
Committer: nickallen <ni...@apache.org>
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