From b83ed4058daa968139c947fbea87af6c81e3e63d Mon Sep 17 00:00:00 2001 From: Xiaohan Song Date: Tue, 15 Oct 2024 17:17:41 -0700 Subject: [PATCH] [source-mysql-v2] fix for incorrect judging criteria (#46930) --- airbyte-integrations/connectors/source-mysql-v2/metadata.yaml | 2 +- .../integrations/source/mysql/cdc/MySqlDebeziumOperations.kt | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/airbyte-integrations/connectors/source-mysql-v2/metadata.yaml b/airbyte-integrations/connectors/source-mysql-v2/metadata.yaml index a697e2fb15ef..60b1270ee01c 100644 --- 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/airbyte-integrations/connectors/source-mysql-v2/src/main/kotlin/io/airbyte/integrations/source/mysql/cdc/MySqlDebeziumOperations.kt b/airbyte-integrations/connectors/source-mysql-v2/src/main/kotlin/io/airbyte/integrations/source/mysql/cdc/MySqlDebeziumOperations.kt index 3daac283ab8a..3b6777c136ea 100644 --- a/airbyte-integrations/connectors/source-mysql-v2/src/main/kotlin/io/airbyte/integrations/source/mysql/cdc/MySqlDebeziumOperations.kt +++ b/airbyte-integrations/connectors/source-mysql-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" }