- change long to int and update docs

Raiffeisen-DGTL · Dec 26, 2024 · f1d2f6f · f1d2f6f
1 parent 5cddf83
commit f1d2f6f
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 2 deletions.
diff --git a/checkita-core/src/main/scala/org/checkita/dqf/config/jobconf/Schemas.scala b/checkita-core/src/main/scala/org/checkita/dqf/config/jobconf/Schemas.scala
@@ -161,7 +161,7 @@ object Schemas {
                                          metadata: Seq[SparkParam] = Seq.empty,
                                          connectionTimeoutMs: Int = 60000,
                                          retryAttempts: Int = 3,
-                                         retryIntervalMs: Long = 5000L
+                                         retryIntervalMs: Int = 5000
                                        ) extends SchemaConfig
 
 }
diff --git a/checkita-core/src/main/scala/org/checkita/dqf/readers/SchemaReaders.scala b/checkita-core/src/main/scala/org/checkita/dqf/readers/SchemaReaders.scala
@@ -242,7 +242,7 @@ object SchemaReaders {
      * @return          The result of the successfully executed function, or throws an exception if all attempts fail.
      */
     @tailrec
-    private def retry(attempts: Int, backOffMs: Long)(fn: => String): String = {
+    private def retry(attempts: Int, backOffMs: Int)(fn: => String): String = {
       Try(fn) match {
         case Success(result) => result
         case Failure(e) =>

diff --git a/docs/03-job-configuration/02-Schemas.md b/docs/03-job-configuration/02-Schemas.md
@@ -127,6 +127,10 @@ To retrieve schema from Confluent Schema Registry it is required to set up follo
   sequence of strings in format `key=value`.
 * `metadata` - *Optional*. List of user-defined metadata parameters specific to this schema where each parameter
   is a string in format: `param.name=param.value`.
+* `connectionTimeoutMs` - *Optional*, default is 60000. Maximum time in milliseconds to wait 
+  for a response from the Schema Registry.
+* `retryAttempts` - *Optional*, default is 3. Number of retry attempts in case of a failure.
+* `retryIntervalMs` - *Optional*, default is 5000. Delay in milliseconds between retry attempts.
 
 ## Supported Type Literals