diff --git a/timeseries/scala/timeseries-weather/src/main/scala/com/databricks/apps/WeatherClientApp.scala b/timeseries/scala/timeseries-weather/src/main/scala/com/databricks/apps/WeatherClientApp.scala
index 9c8d3b1..1a4b242 100644
--- a/timeseries/scala/timeseries-weather/src/main/scala/com/databricks/apps/WeatherClientApp.scala
+++ b/timeseries/scala/timeseries-weather/src/main/scala/com/databricks/apps/WeatherClientApp.scala
@@ -15,8 +15,6 @@
  */
 package com.databricks.apps
 
-import com.sun.deploy.config.ConfigFactory
-
 import scala.collection.immutable
 import akka.actor._
 import akka.cluster.Cluster
diff --git a/timeseries/scala/timeseries-weather/src/main/scala/com/databricks/apps/weather/WeatherApiQueries.scala b/timeseries/scala/timeseries-weather/src/main/scala/com/databricks/apps/weather/WeatherApiQueries.scala
index 03a8d59..25ca48c 100644
--- a/timeseries/scala/timeseries-weather/src/main/scala/com/databricks/apps/weather/WeatherApiQueries.scala
+++ b/timeseries/scala/timeseries-weather/src/main/scala/com/databricks/apps/weather/WeatherApiQueries.scala
@@ -22,6 +22,7 @@ import scala.concurrent.duration._
 import akka.actor._
 import com.datastax.spark.connector.embedded.Event
 import org.joda.time.{DateTime, DateTimeZone}
+import scala.collection.JavaConversions._
 
 class WeatherApiQueries(settings: WeatherSettings, actor: ActorSelection)
   extends AggregationActor with ActorLogging {
@@ -78,7 +79,7 @@ class WeatherApiQueries(settings: WeatherSettings, actor: ActorSelection)
     log.info("Requesting weather station {}", sample.wsid)
     actor ! GetWeatherStation(sample.wsid)
 
-    queried += sample
+    queried = queried + sample
   }
 
   def getLines(file: JFile): Stream[String] = {