From 6f079bcc8faebac9bc699c61a155d8b3219f5146 Mon Sep 17 00:00:00 2001
From: fjy <fangjin@metamarkets.com>
Date: Thu, 5 Dec 2013 17:01:55 -0800
Subject: [PATCH] fix segment id for ii

---
 .../src/main/java/io/druid/segment/realtime/plumber/Sink.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/server/src/main/java/io/druid/segment/realtime/plumber/Sink.java b/server/src/main/java/io/druid/segment/realtime/plumber/Sink.java
index 91edc45e266..e2759406eef 100644
--- a/server/src/main/java/io/druid/segment/realtime/plumber/Sink.java
+++ b/server/src/main/java/io/druid/segment/realtime/plumber/Sink.java
@@ -178,12 +178,12 @@ public class Sink implements Iterable<FireHydrant>
     FireHydrant old;
     if (currIndex == null) {  // Only happens on initialization, cannot synchronize on null
       old = currIndex;
-      currIndex = new FireHydrant(newIndex, hydrants.size(), version);
+      currIndex = new FireHydrant(newIndex, hydrants.size(), getSegment().getIdentifier());
       hydrants.add(currIndex);
     } else {
       synchronized (currIndex) {
         old = currIndex;
-        currIndex = new FireHydrant(newIndex, hydrants.size(), version);
+        currIndex = new FireHydrant(newIndex, hydrants.size(), getSegment().getIdentifier());
         hydrants.add(currIndex);
       }
     }