From 2c5562b6ff2d202cbab2ffbe4836296bc55eac46 Mon Sep 17 00:00:00 2001 From: fjy Date: Fri, 6 Dec 2013 10:29:22 -0800 Subject: [PATCH] fix wrong shard spec --- .../java/io/druid/segment/realtime/plumber/RealtimePlumber.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/server/src/main/java/io/druid/segment/realtime/plumber/RealtimePlumber.java b/server/src/main/java/io/druid/segment/realtime/plumber/RealtimePlumber.java index e7a09df689a..dabf462d418 100644 --- 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) ),