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);
}
|