helix-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From s..@apache.org
Subject git commit: Add additional null check for external view update pipeline
Date Sat, 16 Feb 2013 00:11:50 GMT
Updated Branches:
  refs/heads/master 92a446068 -> e46f0a1a7


Add additional null check for external view update pipeline

Project: http://git-wip-us.apache.org/repos/asf/incubator-helix/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-helix/commit/e46f0a1a
Tree: http://git-wip-us.apache.org/repos/asf/incubator-helix/tree/e46f0a1a
Diff: http://git-wip-us.apache.org/repos/asf/incubator-helix/diff/e46f0a1a

Branch: refs/heads/master
Commit: e46f0a1a7476504c36e1af481047b2a3b9b4eba4
Parents: 92a4460
Author: slu2011 <lushi04@gmail.com>
Authored: Fri Feb 15 16:11:39 2013 -0800
Committer: slu2011 <lushi04@gmail.com>
Committed: Fri Feb 15 16:11:39 2013 -0800

----------------------------------------------------------------------
 .../stages/ExternalViewComputeStage.java           |    2 +-
 1 files changed, 1 insertions(+), 1 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-helix/blob/e46f0a1a/helix-core/src/main/java/org/apache/helix/controller/stages/ExternalViewComputeStage.java
----------------------------------------------------------------------
diff --git a/helix-core/src/main/java/org/apache/helix/controller/stages/ExternalViewComputeStage.java
b/helix-core/src/main/java/org/apache/helix/controller/stages/ExternalViewComputeStage.java
index ec57c17..c8f423a 100644
--- a/helix-core/src/main/java/org/apache/helix/controller/stages/ExternalViewComputeStage.java
+++ b/helix-core/src/main/java/org/apache/helix/controller/stages/ExternalViewComputeStage.java
@@ -139,7 +139,7 @@ public class ExternalViewComputeStage extends AbstractBaseStage
         // For SCHEDULER_TASK_RESOURCE resource group (helix task queue), we need to find
out which task 
         // partitions are finished (COMPLETED or ERROR), update the status update of the
original scheduler 
         // message, and then remove the partitions from the ideal state
-        if(idealState.getStateModelDefRef().equalsIgnoreCase(DefaultSchedulerMessageHandlerFactory.SCHEDULER_TASK_QUEUE))
+        if(idealState != null && idealState.getStateModelDefRef().equalsIgnoreCase(DefaultSchedulerMessageHandlerFactory.SCHEDULER_TASK_QUEUE))
         {
           updateScheduledTaskStatus(view, manager, idealState);
         }


Mime
View raw message