From 138972ded32ba75c943bbae8c6e4221fb3431b32 Mon Sep 17 00:00:00 2001
From: Johnny Schmidt <john.schmidt@airbyte.io>
Date: Wed, 9 Oct 2024 12:42:57 -0700
Subject: [PATCH] Bulk Load CDK: Bugfix: Checkpoint manager allows duplicate
 indexes (#46688)

---
 .../main/kotlin/io/airbyte/cdk/load/state/CheckpointManager.kt  | 2 +-
 1 file changed, 1 insertion(+), 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
index 7a999616c45aa..6963c214b371f 100644
--- 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)"
                 )