From 6f25f8230e20b7f0d7ecfa23c3d5c1af1f117fc4 Mon Sep 17 00:00:00 2001 From: Rodi Reich Zilberman <867491+rodireich@users.noreply.github.com> Date: Wed, 20 Nov 2024 09:34:01 -0800 Subject: [PATCH] =?UTF-8?q?A=20saved=20state=20integer=20should=20map=20to?= =?UTF-8?q?=20the=20largest=20possible=20big=20int=20-=20re=E2=80=A6=20(#4?= =?UTF-8?q?8575)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- airbyte-integrations/connectors/source-mysql/metadata.yaml | 2 +- .../integrations/source/mysql/MysqlJdbcPartitionFactory.kt | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/airbyte-integrations/connectors/source-mysql/metadata.yaml b/airbyte-integrations/connectors/source-mysql/metadata.yaml index a7eec539078a2..cda123c067486 100644 --- a/airbyte-integrations/connectors/source-mysql/metadata.yaml +++ b/airbyte-integrations/connectors/source-mysql/metadata.yaml @@ -9,7 +9,7 @@ data: connectorSubtype: database connectorType: source definitionId: 435bb9a5-7887-4809-aa58-28c27df0d7ad - dockerImageTag: 3.9.0-rc.15 + dockerImageTag: 3.9.0-rc.16 dockerRepository: airbyte/source-mysql documentationUrl: https://docs.airbyte.com/integrations/sources/mysql githubIssueLabel: source-mysql diff --git a/airbyte-integrations/connectors/source-mysql/src/main/kotlin/io/airbyte/integrations/source/mysql/MysqlJdbcPartitionFactory.kt b/airbyte-integrations/connectors/source-mysql/src/main/kotlin/io/airbyte/integrations/source/mysql/MysqlJdbcPartitionFactory.kt index 310966e7ced4e..7b6c0a4d0692a 100644 --- a/airbyte-integrations/connectors/source-mysql/src/main/kotlin/io/airbyte/integrations/source/mysql/MysqlJdbcPartitionFactory.kt +++ b/airbyte-integrations/connectors/source-mysql/src/main/kotlin/io/airbyte/integrations/source/mysql/MysqlJdbcPartitionFactory.kt @@ -297,7 +297,7 @@ class MysqlJdbcPartitionFactory( is LeafAirbyteSchemaType -> return when (field.type.airbyteSchemaType as LeafAirbyteSchemaType) { LeafAirbyteSchemaType.INTEGER -> { - Jsons.valueToTree(stateValue?.toInt()) + Jsons.valueToTree(stateValue?.toBigInteger()) } LeafAirbyteSchemaType.NUMBER -> { Jsons.valueToTree(stateValue?.toDouble())