You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@helix.apache.org by sl...@apache.org on 2013/02/20 22:52:47 UTC
git commit: [Helix-7] tune test parameters for intermittent test
failures
Updated Branches:
refs/heads/master 7d4546720 -> 11ba1bd01
[Helix-7] tune test parameters for intermittent test failures
Project: http://git-wip-us.apache.org/repos/asf/incubator-helix/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-helix/commit/11ba1bd0
Tree: http://git-wip-us.apache.org/repos/asf/incubator-helix/tree/11ba1bd0
Diff: http://git-wip-us.apache.org/repos/asf/incubator-helix/diff/11ba1bd0
Branch: refs/heads/master
Commit: 11ba1bd01afee361d092b99bffdf253ff493784c
Parents: 7d45467
Author: slu2011 <lu...@gmail.com>
Authored: Wed Feb 20 13:52:38 2013 -0800
Committer: slu2011 <lu...@gmail.com>
Committed: Wed Feb 20 13:52:38 2013 -0800
----------------------------------------------------------------------
.../helix/integration/TestSchedulerMessage.java | 4 +++-
1 files changed, 3 insertions(+), 1 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-helix/blob/11ba1bd0/helix-core/src/test/java/org/apache/helix/integration/TestSchedulerMessage.java
----------------------------------------------------------------------
diff --git a/helix-core/src/test/java/org/apache/helix/integration/TestSchedulerMessage.java b/helix-core/src/test/java/org/apache/helix/integration/TestSchedulerMessage.java
index 23ce790..627e1cb 100644
--- a/helix-core/src/test/java/org/apache/helix/integration/TestSchedulerMessage.java
+++ b/helix-core/src/test/java/org/apache/helix/integration/TestSchedulerMessage.java
@@ -48,6 +48,7 @@ import org.apache.helix.messaging.handling.MessageHandlerFactory;
import org.apache.helix.model.Message;
import org.apache.helix.model.Message.MessageState;
import org.apache.helix.model.Message.MessageType;
+import org.apache.helix.model.StatusUpdate;
import org.apache.helix.monitoring.ZKPathDataDumpTask;
import org.apache.helix.util.HelixUtil;
import org.codehaus.jackson.JsonGenerationException;
@@ -521,7 +522,8 @@ public class TestSchedulerMessage extends ZkStandAloneCMTestBaseWithPropertyServ
MessageType.SCHEDULER_MSG.toString(), schedulerMessage.getMsgId());
for(int i = 0; i< 10; i++)
{
- if(helixDataAccessor.getProperty(controllerTaskStatus) == null)
+ StatusUpdate update = helixDataAccessor.getProperty(controllerTaskStatus);
+ if(update == null || update.getRecord().getMapField("SentMessageCount") == null)
{
Thread.sleep(1000);
}