diff --git a/src/main/scala/weather/data/demo/WeatherDataFromCassandra.scala b/src/main/scala/weather/data/demo/WeatherDataFromCassandra.scala
index 10dad82..34c02cc 100644
--- a/src/main/scala/weather/data/demo/WeatherDataFromCassandra.scala
+++ b/src/main/scala/weather/data/demo/WeatherDataFromCassandra.scala
@@ -15,7 +15,7 @@ object WeatherDataFromCassandra {
   def main (args: Array[String]) {
 
     val conf = new SparkConf(true)
-      .setAppName("write_csv_to_cassandra")
+      .setAppName("weather_data_from_cassandra")
       .setMaster("local[2]")
       .set("spark.cassandra.input.page.row.size","10000")
       .set("spark.cassandra.input.split.size","1000000")
diff --git a/src/main/scala/weather/data/demo/WeatherDataIntoCassandra.scala b/src/main/scala/weather/data/demo/WeatherDataIntoCassandra.scala
index 9a4d651..10ba0c9 100644
--- a/src/main/scala/weather/data/demo/WeatherDataIntoCassandra.scala
+++ b/src/main/scala/weather/data/demo/WeatherDataIntoCassandra.scala
@@ -16,9 +16,11 @@ object WeatherDataIntoCassandra {
   def main (args: Array[String]) {
 
     val conf = new SparkConf(true)
-      .setAppName("write_csv_to_cassandra")
+      .setAppName("weather_data_into_cassandra")
       .setMaster("local[2]")
       .set("spark.cassandra.connection.host", "localhost")
+      .set("spark.cassandra.output.batch.size.bytes", "1024")
+      .set("spark.cassandra.output.batch.size.rows", "100")
 
     val sc = new SparkContext(conf)