StringDimensionSchema cast exception when moving from dimension-less to explicitly listing dimension

When I switch my schema from using :

“dimensionsSpec” : {

“dimensions” : ,

“dimensionExclusions” :

},

TO

“dimensionsSpec” : {

“dimensions” : [“user_id”,“team_id”,… ], // listing all the dimensions

“dimensionExclusions” :

},

I get the following error:

2017-01-27 21:36:13,249 [KafkaConsumer-2] INFO c.m.t.kafka.writer.WriterController - Creating EventWriter for topic [activity-json] using dataSource [metrics-activity]

2017-01-27 21:36:13,251 [KafkaConsumer-1] ERROR c.m.tranquility.kafka.KafkaConsumer - Exception:

java.lang.ClassCastException: io.druid.data.input.impl.StringDimensionSchema cannot be cast to java.lang.String

at com.metamx.tranquility.druid.DruidRollup$$anonfun$4.apply(DruidRollup.scala:53) ~[io.druid.tranquility-core-0.8.1.jar:0.8.1]

at scala.collection.TraversableLike$$anonfun$groupBy$1.apply(TraversableLike.scala:332) ~[org.scala-lang.scala-library-2.11.7.jar:na]

at scala.collection.TraversableLike$$anonfun$groupBy$1.apply(TraversableLike.scala:331) ~[org.scala-lang.scala-library-2.11.7.jar:na]

at scala.collection.immutable.List.foreach(List.scala:381) ~[org.scala-lang.scala-library-2.11.7.jar:na]

at scala.collection.TraversableLike$class.groupBy(TraversableLike.scala:331) ~[org.scala-lang.scala-library-2.11.7.jar:na]

at scala.collection.AbstractTraversable.groupBy(Traversable.scala:104) ~[org.scala-lang.scala-library-2.11.7.jar:na]

at com.metamx.tranquility.druid.DruidRollup.validate(DruidRollup.scala:53) ~[io.druid.tranquility-core-0.8.1.jar:0.8.1]

at com.metamx.tranquility.druid.DruidRollup.(DruidRollup.scala:46) ~[io.druid.tranquility-core-0.8.1.jar:0.8.1]

at com.metamx.tranquility.druid.DruidRollup$.apply(DruidRollup.scala:182) ~[io.druid.tranquility-core-0.8.1.jar:0.8.1]

at com.metamx.tranquility.druid.DruidBeams$.fromConfigInternal(DruidBeams.scala:309) ~[io.druid.tranquility-core-0.8.1.jar:0.8.1]

at com.metamx.tranquility.druid.DruidBeams$.fromConfig(DruidBeams.scala:202) ~[io.druid.tranquility-core-0.8.1.jar:0.8.1]

at com.metamx.tranquility.kafka.KafkaBeamUtils$.createTranquilizer(KafkaBeamUtils.scala:40) ~[io.druid.tranquility-kafka-0.8.1.jar:0.8.1]

at com.metamx.tranquility.kafka.KafkaBeamUtils.createTranquilizer(KafkaBeamUtils.scala) ~[io.druid.tranquility-kafka-0.8.1.jar:0.8.1]

at com.metamx.tranquility.kafka.writer.TranquilityEventWriter.(TranquilityEventWriter.java:64) ~[io.druid.tranquility-kafka-0.8.1.jar:0.8.1]

at com.metamx.tranquility.kafka.writer.WriterController.createWriter(WriterController.java:171) ~[io.druid.tranquility-kafka-0.8.1.jar:0.8.1]

at com.metamx.tranquility.kafka.writer.WriterController.getWriter(WriterController.java:98) ~[io.druid.tranquility-kafka-0.8.1.jar:0.8.1]

at com.metamx.tranquility.kafka.KafkaConsumer$2.run(KafkaConsumer.java:231) ~[io.druid.tranquility-kafka-0.8.1.jar:0.8.1]

at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_101]

at java.util.concurrent.FutureTask.run(FutureTask.java:266) [na:1.8.0_101]

at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [na:1.8.0_101]

at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [na:1.8.0_101]

at java.lang.Thread.run(Thread.java:745) [

I am using tranquility 0.8.1 and druid 0.9.2

Any help/insight would be great. dimension-less schema works great, however I do want to have some dimensions that are metrics rollups AND unique dims. From what I understand, you can do that if you explicitly list your dimensions but not with a dimension-less schema.

Thanks