commit 80e145328e3f09bbcd932efe988bc4a4efd9440f
author buyingyi <buyingyi@gmail.com> Sun Sep 01 15:42:14 2013 -0700
committer buyingyi <buyingyi@gmail.com> Sun Sep 01 15:42:14 2013 -0700
tree b810bf4a9f92eb21753e1cf8f6d0e31fd7f8bfc9
parent 76b99066518e569768663c27f7f2054fe148f6bf

1. simply activity cluster planner for all-producers-to-all-consumers kind of connectors; 2. lower the NC task threads' priority

pregelix-core/src/main/java/edu/uci/ics/pregelix/core/util/PregelixHyracksIntegrationUtil.java

diff --git a/pregelix-core/src/main/java/edu/uci/ics/pregelix/core/util/PregelixHyracksIntegrationUtil.java b/pregelix-core/src/main/java/edu/uci/ics/pregelix/core/util/PregelixHyracksIntegrationUtil.java
index f4b26cb..279de61 100644
--- a/pregelix-core/src/main/java/edu/uci/ics/pregelix/core/util/PregelixHyracksIntegrationUtil.java
+++ b/pregelix-core/src/main/java/edu/uci/ics/pregelix/core/util/PregelixHyracksIntegrationUtil.java
@@ -61,9 +61,9 @@
         ccConfig.defaultMaxJobAttempts = 0;
         ccConfig.jobHistorySize = 1;
         ccConfig.profileDumpPeriod = -1;
-        ccConfig.heartbeatPeriod = 5000;
-        ccConfig.maxHeartbeatLapsePeriods = 8;
-
+        ccConfig.heartbeatPeriod = 1000;
+        ccConfig.maxHeartbeatLapsePeriods = 10;
+        
         // cluster controller
         cc = new ClusterControllerService(ccConfig);
         cc.start();