From 456075e6183ecbba104f12cdd60a9e040314613d Mon Sep 17 00:00:00 2001 From: Gianpaolo Coro Date: Fri, 30 Sep 2016 12:38:02 +0000 Subject: [PATCH] git-svn-id: https://svn.d4science.research-infrastructures.eu/gcube/trunk/data-analysis/EcologicalEngineGeoSpatialExtension@132189 82a268e6-3cf1-43bd-a215-b396298e98cf --- .../dataanalysis/geo/algorithms/MapsComparatorNode.java | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/src/main/java/org/gcube/dataanalysis/geo/algorithms/MapsComparatorNode.java b/src/main/java/org/gcube/dataanalysis/geo/algorithms/MapsComparatorNode.java index 98fce90..79c1dfb 100644 --- a/src/main/java/org/gcube/dataanalysis/geo/algorithms/MapsComparatorNode.java +++ b/src/main/java/org/gcube/dataanalysis/geo/algorithms/MapsComparatorNode.java @@ -22,7 +22,7 @@ import org.gcube.dataanalysis.ecoengine.utils.IOHelper; import org.gcube.dataanalysis.ecoengine.utils.Transformations; import org.gcube.dataanalysis.ecoengine.utils.Tuple; import org.gcube.dataanalysis.executor.generators.D4ScienceDistributedProcessing; -import org.gcube.dataanalysis.executor.job.management.QueueJobManager; + import org.gcube.dataanalysis.geo.connectors.netcdf.NetCDFDataExplorer; import org.gcube.dataanalysis.geo.infrastructure.GeoNetworkInspector; import org.gcube.dataanalysis.geo.matrixmodel.MatrixExtractor; @@ -316,10 +316,6 @@ public class MapsComparatorNode extends ActorNode{ prevmaxMessages=D4ScienceDistributedProcessing.maxMessagesAllowedPerJob; D4ScienceDistributedProcessing.maxMessagesAllowedPerJob=1; - prevbroadcastTimePeriod = QueueJobManager.broadcastTimePeriod; - QueueJobManager.broadcastTimePeriod=4*3600000; - prevmaxNumberOfStages = QueueJobManager.maxNumberOfStages; - QueueJobManager.maxNumberOfStages=10000; AnalysisLogger.getLogger().info("Destination Table Created! Addressing " + numberofslices + " slices"); }