From d5c2fd604f4200fe2e93abdf4e2e199271a3a7de Mon Sep 17 00:00:00 2001
From: fjy <fangjin@metamarkets.com>
Date: Fri, 31 May 2013 16:28:41 -0700
Subject: [PATCH] add new preconditions for taskqueue

---
 .../main/java/com/metamx/druid/merger/coordinator/TaskQueue.java | 1 +
 1 file changed, 1 insertion(+)

diff --git a/merger/src/main/java/com/metamx/druid/merger/coordinator/TaskQueue.java b/merger/src/main/java/com/metamx/druid/merger/coordinator/TaskQueue.java
index 203983ef556..fdb053c764f 100644
--- a/merger/src/main/java/com/metamx/druid/merger/coordinator/TaskQueue.java
+++ b/merger/src/main/java/com/metamx/druid/merger/coordinator/TaskQueue.java
@@ -219,6 +219,7 @@ public class TaskQueue
 
     try {
       Preconditions.checkState(active, "Queue is not active!");
+      Preconditions.checkNotNull(task, "task");
 
       // If this throws with any sort of exception, including TaskExistsException, we don't want to
       // insert the task into our queue.