Port mysql divizion by zero fix to the CDK (#66674)

Author: rodireich

airbyte-cdk/bulk/changelog.md

@@ -1,3 +1,9 @@
+## Version 0.1.41
+
+**Extract CDK**
+
+* **Changed:** Prevent a devision by zero error when a table cannot be partitioned.
+
 ## Version 0.1.40
 
 Add gradle task to bump CDK version + add changelog entry

airbyte-cdk/bulk/toolkits/extract-jdbc/src/main/kotlin/io/airbyte/cdk/read/JdbcPartitionsCreator.kt

@@ -253,6 +253,14 @@ class JdbcConcurrentPartitionsCreator<
                 .filter { random.nextDouble() < secondarySamplingRate }
                 .mapNotNull { (splitBoundary: OpaqueStateValue?, _) -> splitBoundary }
                 .distinct()
+
+        // Handle edge case with empty split boundaries when sampling rate is too low,
+        // causing random filtering to discard all sampled boundaries, which would
+        // lead to division by zero the in the split() function. Fall back to single partition.
+        if (splitBoundaries.isEmpty()) {
+            log.warn { "No split boundaries found, using single partition" }
+            return listOf(JdbcNonResumablePartitionReader(partition))
+        }
         val partitions: List<JdbcPartition<*>> = partitionFactory.split(partition, splitBoundaries)
         log.info { "Table will be read by ${partitions.size} concurrent partition reader(s)." }
         return partitions.map { JdbcNonResumablePartitionReader(it) }

airbyte-cdk/bulk/version.properties

@@ -1 +1 @@
-version=0.1.40
+version=0.1.41