Update MQTTInputDStream.scala