#687 Fix PR suggestions including typos in comments, exception messages, and documentation for consistency.

Author: yruslan

README.md

@@ -3473,13 +3473,13 @@ execution Pramen will do the following:
     - `2` means backfill for the info date and the date before.
 - Check for retrospective updates of the source data according to `track.days` of corresponding tables in the metastore.
   For this check Pramen will query sources for record counts for each of previous days.
+  - The option has the following meaning (similar to `backfill.days``):
+      - `-1` means backfill only up until the last successfull attempt. Never track retrospective updates.
+      - `0` means never track retrospective updates.
+      - `1` means track retrospective only for the same info date.
+      - `2` means track retrospective for the info date and the date before.
   - If a mismatch is found (as at `2020-07-16` on this diagram), the data is reloaded and dependent transformers are
     recomputed (if `trigger.updates = true`)
-  - The option has the following meaning (similar to `backfill.days``):
-    - `-1` means backfill only up until the last successfull attempt. Never track retrospective updates.
-    - `0` means never track retrospective updates.
-    - `1` means track retrospective only for the same info date.
-    - `2` means track retrospective for the info date and the date before.
 - Check for late data by querying sources for records for previous days if none were loaded. If such data is found, it
   is loaded and related transformations will be ran.
 - Run the pipeline for the day - check new data and run dependent transformers and sink jobs.

pramen/core/src/main/resources/reference.conf

@@ -68,13 +68,13 @@ pramen {
   wait.for.output.table.enabled = false
   wait.for.output.table.seconds = 600
 
-  # How many days to check back for late data (when there is not data at the source for that day)
-  # 0 - never check previous days, even if no data at the source happenned
+  # How many days to check back for late data (when there is no data at the source for that day)
+  # 0 - never check previous days, even if no data at the source happened
   # 1 - check only the current info date if you run the job more than once per day
   # 2 - check the latest info date and the date before
   # etc...
   # You can also set this parameter for individual tables in the metastore.
-  # NOTE. By default it is the same as track days, so it won't take effect. In order for it to take effect you
+  # NOTE. By default it is the same as track.days, so it won't take effect. In order for it to take effect you
   #       need to either increase 'backfill.days' and/or decrease 'track.days'
   backfill.days = 5
 

pramen/core/src/main/scala/za/co/absa/pramen/core/bookkeeper/BookkeeperBase.scala

@@ -134,7 +134,7 @@ abstract class BookkeeperBase(isBookkeepingEnabled: Boolean, batchId: Long) exte
   }
 
   private[pramen] override def getOffsetManager: OffsetManager = {
-    throw new IllegalArgumentException(s"This implementation of bookeeping does not support offset management and incremental pipelines. " +
+    throw new IllegalArgumentException(s"This implementation of bookkeeping does not support offset management and incremental pipelines. " +
       "Please, use JDBC for bookkeeping to enable this.")
   }
 
@@ -180,7 +180,7 @@ abstract class BookkeeperBase(isBookkeepingEnabled: Boolean, batchId: Long) exte
     val foundDataAvailable = new ListBuffer[DataAvailability]
 
     while (date.isBefore(dateEndPlus)) {
-      val chunks = getTransientDataChunks(table, Option(date), None, None)
+      val chunks = getTransientDataChunks(table, Option(date), Option(date), None)
 
       if (chunks.nonEmpty) {
         val totalRecords = chunks.map(_.outputRecordCount).sum

pramen/core/src/main/scala/za/co/absa/pramen/core/rdb/PramenDb.scala

@@ -155,7 +155,7 @@ object PramenDb {
         slick.jdbc.MySQLProfile
       case "com.microsoft.sqlserver.jdbc.SQLServerDriver" | "net.sourceforge.jtds.jdbc.Driver" =>
         slick.jdbc.SQLServerProfile
-      case other => throw new IllegalArgumentException(s"Unknown driver for the bookeeping database: $other")
+      case other => throw new IllegalArgumentException(s"Unknown driver for the bookkeeping database: $other")
     }
   }
 

pramen/core/src/test/scala/za/co/absa/pramen/core/mocks/bookkeeper/SyncBookkeeperMock.scala

@@ -97,7 +97,7 @@ class SyncBookkeeperMock(batchId: Long = 123L) extends Bookkeeper {
 
         foundDataAvailable += DataAvailability(
           date,
-          chunks.size,
+          chunksForDate.size,
           totalRecordCount
         )
       }