diff --git a/airbyte-integrations/connectors/source-mysql/metadata.yaml b/airbyte-integrations/connectors/source-mysql/metadata.yaml index a7eec539078a..cda123c06748 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 310966e7ced4..7b6c0a4d0692 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())