Merge pull request #1295 from anubhgup/master

Fix type of values in sql update.
apache · Apr 18, 2015 · 1addbe1 · 1addbe1
2 parents b438ca3 + 4c240da
commit 1addbe1
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/server/src/main/java/io/druid/indexer/SQLMetadataStorageUpdaterJobHandler.java b/server/src/main/java/io/druid/indexer/SQLMetadataStorageUpdaterJobHandler.java
@@ -67,10 +67,10 @@ public Void withHandle(Handle handle) throws Exception
                       .put("created_date", new DateTime().toString())
                       .put("start", segment.getInterval().getStart().toString())
                       .put("end", segment.getInterval().getEnd().toString())
-                      .put("partitioned", (segment.getShardSpec() instanceof NoneShardSpec) ? 0 : 1)
+                      .put("partitioned", (segment.getShardSpec() instanceof NoneShardSpec) ? false : true)
                       .put("version", segment.getVersion())
                       .put("used", true)
-                      .put("payload", mapper.writeValueAsString(segment))
+                      .put("payload", mapper.writeValueAsBytes(segment))
                       .build()
               );