[source-mysql-v2] fix for incorrect judging criteria (#46930)

airbytehq · Oct 16, 2024 · b83ed40 · b83ed40
1 parent ee5e553
commit b83ed40
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/airbyte-integrations/connectors/source-mysql-v2/metadata.yaml b/airbyte-integrations/connectors/source-mysql-v2/metadata.yaml
@@ -9,7 +9,7 @@ data:
   connectorSubtype: database
   connectorType: source
   definitionId: 561393ed-7e3a-4d0d-8b8b-90ded371754c
-  dockerImageTag: 0.0.22
+  dockerImageTag: 0.0.23
   dockerRepository: airbyte/source-mysql-v2
   documentationUrl: https://docs.airbyte.com/integrations/sources/mysql
   githubIssueLabel: source-mysql-v2

diff --git a/...ql-v2/src/main/kotlin/io/airbyte/integrations/source/mysql/cdc/MySqlDebeziumOperations.kt b/...ql-v2/src/main/kotlin/io/airbyte/integrations/source/mysql/cdc/MySqlDebeziumOperations.kt
@@ -115,7 +115,7 @@ class MySqlDebeziumOperations(
         val newGtidSet = availableGtidSet.subtract(savedGtidSet)
         if (!newGtidSet.isEmpty) {
             val purgedGtidSet = queryPurgedIds()
-            if (newGtidSet.subtract(purgedGtidSet).equals(newGtidSet)) {
+            if (!newGtidSet.subtract(purgedGtidSet).equals(newGtidSet)) {
                 log.info {
                     "Connector has not seen GTIDs $newGtidSet, but MySQL server has purged $purgedGtidSet"
                 }