fix wrong shard spec

2013-12-06 10:29:22 -08:00 · 2013-12-06 10:29:22 -08:00 · 2c5562b6ff
parent f8ff9296bc
commit 2c5562b6ff
1 changed files with 1 additions and 1 deletions
--- a/server/src/main/java/io/druid/segment/realtime/plumber/RealtimePlumber.java
+++ b/server/src/main/java/io/druid/segment/realtime/plumber/RealtimePlumber.java
@ -517,7 +517,7 @@ public class RealtimePlumber implements Plumber
                          sinkInterval.getStart(),
                          sinkInterval.getEnd(),
                          versioningPolicy.getVersion(sinkInterval),
-                          new NoneShardSpec()
+                          schema.getShardSpec()
                      ),
                      IndexIO.loadIndex(segmentDir)
                  ),