Bulk Load CDK: Bugfix: Checkpoint manager allows duplicate indexes (#…

…46688)
airbytehq · Oct 9, 2024 · 138972d · 138972d
1 parent d6eb912
commit 138972d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/airbyte-cdk/bulk/core/load/src/main/kotlin/io/airbyte/cdk/load/state/CheckpointManager.kt b/airbyte-cdk/bulk/core/load/src/main/kotlin/io/airbyte/cdk/load/state/CheckpointManager.kt
@@ -186,7 +186,7 @@ abstract class StreamsCheckpointManager<T> : CheckpointManager<DestinationStream
     ) {
         streamIndexes.forEach { (stream, index) ->
             val lastIndex = lastIndexEmitted[stream]
-            if (lastIndex != null && index <= lastIndex) {
+            if (lastIndex != null && index < lastIndex) {
                 throw IllegalStateException(
                     "Checkpoint message for $stream emitted out of order (emitting $index after $lastIndex)"
                 )