Dec 3, 2016 8:46:34 PM INFO: org.apache.parqu^[[31m- Recovering offset from the last processed offset. *** FAILED ***^[[0m
^[[31m  java.util.NoSuchElementException: None.get^[[0m
^[[31m  at scala.None$.get(Option.scala:347)^[[0m
^[[31m  at scala.None$.get(Option.scala:345)^[[0m
^[[31m  at org.apache.bahir.sql.streaming.mqtt.BasicMQTTSourceSuite$$anonfun$6.apply$mcV$sp(MQTTStreamSourceSuite.scala:166)^[[0m
^[[31m  at org.apache.bahir.sql.streaming.mqtt.BasicMQTTSourceSuite$$anonfun$6.apply(MQTTStreamSourceSuite.scala:146)^[[0m
^[[31m  at org.apache.bahir.sql.streaming.mqtt.BasicMQTTSourceSuite$$anonfun$6.apply(MQTTStreamSourceSuite.scala:146)^[[0m
^[[31m  at org.scalatest.Transformer$$anonfun$apply$1.apply$mcV$sp(Transformer.scala:22)^[[0m
^[[31m  at org.scalatest.OutcomeOf$class.outcomeOf(OutcomeOf.scala:85)^[[0m
^[[31m  at org.scalatest.OutcomeOf$.outcomeOf(OutcomeOf.scala:104)^[[0m
^[[31m  at org.scalatest.Transformer.apply(Transformer.scala:22)^[[0m
^[[31m  at org.scalatest.Transformer.apply(Transformer.scala:20)^[[0m
^[[31m  ...^[[0m

Dec 3, 2016 8:46:^[[31m- Send and receive 100 messages. *** FAILED ***^[[0m
^[[31m  Buffer("MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.", "MQTT is a message queue.") had size 76 instead of expected size 100 (MQTTStreamSourceSuite.scala:119)^[[0m
21 PM INFO: org.apache.parquet.hadoop.ColumnChunkPageWriteStore: written 59B for [timestamp] INT96: 3 values, 8B raw, 10B comp, 1 pages, encodings: [RLE, PLAIN_DICTIONARY, BIT_PACKED], dic { 1 entries, 12B raw, 1B comp}