diff --git a/pdb-plotting/src/main/java/org/lucares/pdb/plot/api/ParallelRequestsAggregate.java b/pdb-plotting/src/main/java/org/lucares/pdb/plot/api/ParallelRequestsAggregate.java index f6d642b..8e877ea 100644 --- a/pdb-plotting/src/main/java/org/lucares/pdb/plot/api/ParallelRequestsAggregate.java +++ b/pdb-plotting/src/main/java/org/lucares/pdb/plot/api/ParallelRequestsAggregate.java @@ -2,6 +2,7 @@ package org.lucares.pdb.plot.api; import java.nio.file.Path; import java.util.Collection; +import java.util.concurrent.TimeUnit; import org.lucares.recommind.logs.DataSeries; @@ -36,7 +37,7 @@ public class ParallelRequestsAggregate implements AggregateHandler { @Override public CustomAggregator createCustomAggregator(final Path tmpDir, final long fromEpochMilli, final long toEpochMilli) { - if ((toEpochMilli - fromEpochMilli) <= 3600 * 1000) { + if ((toEpochMilli - fromEpochMilli) <= TimeUnit.HOURS.toMillis(5)) { return new ParallelRequestsAggregator(tmpDir, fromEpochMilli, toEpochMilli); } else { return new NullCustomAggregator(); diff --git a/pdb-plotting/src/main/java/org/lucares/pdb/plot/api/ParallelRequestsAggregator.java b/pdb-plotting/src/main/java/org/lucares/pdb/plot/api/ParallelRequestsAggregator.java index 96aae69..004f58f 100644 --- a/pdb-plotting/src/main/java/org/lucares/pdb/plot/api/ParallelRequestsAggregator.java +++ b/pdb-plotting/src/main/java/org/lucares/pdb/plot/api/ParallelRequestsAggregator.java @@ -34,11 +34,6 @@ public class ParallelRequestsAggregator implements CustomAggregator { this.fromEpochMilli = fromEpochMilli; this.toEpochMilli = toEpochMilli; - if ((toEpochMilli - fromEpochMilli) > 3600 * 1000) { - throw new IllegalArgumentException("The " + ParallelRequestsAggregator.class.getSimpleName() - + " must only be active for periods shorter than one hour, due to memory concerns."); - } - final int milliseconds = (int) (toEpochMilli - fromEpochMilli); increments = new short[milliseconds]; }