PD-239: Fix logging

pygmalios · Mar 18, 2016 · 3ee1c1d · 3ee1c1d
1 parent f94f9a6
commit 3ee1c1d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/scala/com/pygmalios/reactiveinflux/spark/extensions/PointRDDExtensions.scala b/src/main/scala/com/pygmalios/reactiveinflux/spark/extensions/PointRDDExtensions.scala
@@ -36,7 +36,7 @@ private[spark] class PointRDDExtensions[+T <: PointNoTime](rdd: RDD[T]) extends
         totalBatchCount += batchCount
         totalPointCount += pointCount
 
-        log.debug(s"Partition with $batchCount points written to Influx in $pointCount batches.")
+        log.debug(s"Partition with $pointCount points written to Influx in $batchCount batches.")
       }
     }
     log.info(s"RDD with ${rdd.partitions.size} partitions and $totalPointCount points written to Influx in $totalBatchCount batches.")