Skip to content

MS SQL destination connector doesn't understand UNIQUEIDENTIFIER field type #69224

New issue
New issue
Open
Open
MS SQL destination connector doesn't understand UNIQUEIDENTIFIER field type#69224
Labels
area/connectorsConnector related issuesautoteamcommunityneeds-triageteam/extensibilityteam/usetype/bugSomething isn't working
@ibrentlam

Description

@ibrentlam
ibrentlam
opened on Nov 6, 2025

Connector Name

destination-mssql

Connector Version

2.2.14

What step the error happened?

During the sync

Relevant information

Replication dies with:
Warning from destination: No enum constant io.airbyte.integrations.destination.mssql.v2.convert.MssqlType.UNIQUEIDENTIFIER
java.lang.IllegalArgumentException: No enum constant io.airbyte.integrations.destination.mssql.v2.convert.MssqlType.UNIQUEIDENTIFIER

Relevant log output

2025-11-06 03:41:01 replication-orchestrator INFO Records read: 3180000 (838 MB)
2025-11-06 03:41:01 source INFO main i.a.c.d.j.s.AdaptiveStreamingQueryConfig(accept):33 Set new fetch size: 4534274 rows
2025-11-06 03:41:01 source INFO main i.a.c.d.j.s.AdaptiveStreamingQueryConfig(accept):33 Set new fetch size: 4371774 rows
2025-11-06 03:41:01 destination ERROR DefaultDispatcher-worker-4 i.a.i.d.m.v.AbstractMSSQLStreamLoader(ensureTableExists):51 Error creating/updating the table: No enum constant io.airbyte.integrations.destination.mssql.v2.convert.MssqlType.UNIQUEIDENTIFIER java.lang.IllegalArgumentException: No enum constant io.airbyte.integrations.destination.mssql.v2.convert.MssqlType.UNIQUEIDENTIFIER
	at java.base/java.lang.Enum.valueOf(Enum.java:293) ~[?:?]
	at io.airbyte.integrations.destination.mssql.v2.convert.MssqlType.valueOf(AirbyteTypeToMssqlType.kt) ~[io.airbyte.airbyte-integrations.connectors-destination-mssql.jar:?]
	at io.airbyte.integrations.destination.mssql.v2.MSSQLQueryBuilder$getExistingSchema$1.invoke(MSSQLQueryBuilder.kt:253) ~[io.airbyte.airbyte-integrations.connectors-destination-mssql.jar:?]
	at io.airbyte.integrations.destination.mssql.v2.MSSQLQueryBuilder$getExistingSchema$1.invoke(MSSQLQueryBuilder.kt:250) ~[io.airbyte.airbyte-integrations.connectors-destination-mssql.jar:?]
	at io.airbyte.integrations.destination.mssql.v2.MSSQLQueryBuilderKt.executeQuery(MSSQLQueryBuilder.kt:66) ~[io.airbyte.airbyte-integrations.connectors-destination-mssql.jar:?]
	at io.airbyte.integrations.destination.mssql.v2.MSSQLQueryBuilder.getExistingSchema(MSSQLQueryBuilder.kt:250) ~[io.airbyte.airbyte-integrations.connectors-destination-mssql.jar:?]
	at io.airbyte.integrations.destination.mssql.v2.MSSQLQueryBuilder.updateSchema(MSSQLQueryBuilder.kt:264) ~[io.airbyte.airbyte-integrations.connectors-destination-mssql.jar:?]
	at io.airbyte.integrations.destination.mssql.v2.AbstractMSSQLStreamLoader.ensureTableExists(AbstractMSSQLStreamLoader.kt:48) [io.airbyte.airbyte-integrations.connectors-destination-mssql.jar:?]
	at io.airbyte.integrations.destination.mssql.v2.AbstractMSSQLStreamLoader.start$suspendImpl(AbstractMSSQLStreamLoader.kt:28) [io.airbyte.airbyte-integrations.connectors-destination-mssql.jar:?]
	at io.airbyte.integrations.destination.mssql.v2.AbstractMSSQLStreamLoader.start(AbstractMSSQLStreamLoader.kt) [io.airbyte.airbyte-integrations.connectors-destination-mssql.jar:?]
	at io.airbyte.integrations.destination.mssql.v2.MSSQLStreamLoader.start(MSSQLStreamLoader.kt:19) [io.airbyte.airbyte-integrations.connectors-destination-mssql.jar:?]
	at io.airbyte.cdk.load.task.implementor.OpenStreamTask$execute$2.emit(OpenStreamTask.kt:43) [bulk-cdk-core-load-0.1.61.jar:?]
	at io.airbyte.cdk.load.task.implementor.OpenStreamTask$execute$2.emit(OpenStreamTask.kt:36) [bulk-cdk-core-load-0.1.61.jar:?]
	at kotlinx.coroutines.flow.FlowKt__ChannelsKt.emitAllImpl$FlowKt__ChannelsKt(Channels.kt:33) [kotlinx-coroutines-core-jvm-1.10.2.jar:?]
	at kotlinx.coroutines.flow.FlowKt__ChannelsKt.access$emitAllImpl$FlowKt__ChannelsKt(Channels.kt:1) [kotlinx-coroutines-core-jvm-1.10.2.jar:?]
	at kotlinx.coroutines.flow.FlowKt__ChannelsKt$emitAllImpl$1.invokeSuspend(Channels.kt) [kotlinx-coroutines-core-jvm-1.10.2.jar:?]
	at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33) [kotlin-stdlib-2.1.10.jar:2.1.10-release-473]
	at kotlinx.coroutines.DispatchedTask.run(DispatchedTask.kt:100) [kotlinx-coroutines-core-jvm-1.10.2.jar:?]
	at kotlinx.coroutines.internal.LimitedDispatcher$Worker.run(LimitedDispatcher.kt:124) [kotlinx-coroutines-core-jvm-1.10.2.jar:?]
	at kotlinx.coroutines.scheduling.TaskImpl.run(Tasks.kt:89) [kotlinx-coroutines-core-jvm-1.10.2.jar:?]
	at kotlinx.coroutines.scheduling.CoroutineScheduler.runSafely(CoroutineScheduler.kt:586) [kotlinx-coroutines-core-jvm-1.10.2.jar:?]
	at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.executeTask(CoroutineScheduler.kt:820) [kotlinx-coroutines-core-jvm-1.10.2.jar:?]
	at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.runWorker(CoroutineScheduler.kt:717) [kotlinx-coroutines-core-jvm-1.10.2.jar:?]
	at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.run(CoroutineScheduler.kt:704) [kotlinx-coroutines-core-jvm-1.10.2.jar:?]

Stack Trace: java.lang.IllegalArgumentException: No enum constant io.airbyte.integrations.destination.mssql.v2.convert.MssqlType.UNIQUEIDENTIFIER
	at java.base/java.lang.Enum.valueOf(Enum.java:293)
	at io.airbyte.integrations.destination.mssql.v2.convert.MssqlType.valueOf(AirbyteTypeToMssqlType.kt)
	at io.airbyte.integrations.destination.mssql.v2.MSSQLQueryBuilder$getExistingSchema$1.invoke(MSSQLQueryBuilder.kt:253)
	at io.airbyte.integrations.destination.mssql.v2.MSSQLQueryBuilder$getExistingSchema$1.invoke(MSSQLQueryBuilder.kt:250)
	at io.airbyte.integrations.destination.mssql.v2.MSSQLQueryBuilderKt.executeQuery(MSSQLQueryBuilder.kt:66)
	at io.airbyte.integrations.destination.mssql.v2.MSSQLQueryBuilder.getExistingSchema(MSSQLQueryBuilder.kt:250)
	at io.airbyte.integrations.destination.mssql.v2.MSSQLQueryBuilder.updateSchema(MSSQLQueryBuilder.kt:264)
	at io.airbyte.integrations.destination.mssql.v2.AbstractMSSQLStreamLoader.ensureTableExists(AbstractMSSQLStreamLoader.kt:48)
	at io.airbyte.integrations.destination.mssql.v2.AbstractMSSQLStreamLoader.start$suspendImpl(AbstractMSSQLStreamLoader.kt:28)
	at io.airbyte.integrations.destination.mssql.v2.AbstractMSSQLStreamLoader.start(AbstractMSSQLStreamLoader.kt)
	at io.airbyte.integrations.destination.mssql.v2.MSSQLStreamLoader.start(MSSQLStreamLoader.kt:19)
	at io.airbyte.cdk.load.task.implementor.OpenStreamTask$execute$2.emit(OpenStreamTask.kt:43)
	at io.airbyte.cdk.load.task.implementor.OpenStreamTask$execute$2.emit(OpenStreamTask.kt:36)
	at kotlinx.coroutines.flow.FlowKt__ChannelsKt.emitAllImpl$FlowKt__ChannelsKt(Channels.kt:33)
	at kotlinx.coroutines.flow.FlowKt__ChannelsKt.access$emitAllImpl$FlowKt__ChannelsKt(Channels.kt:1)
	at kotlinx.coroutines.flow.FlowKt__ChannelsKt$emitAllImpl$1.invokeSuspend(Channels.kt)
	at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33)
	at kotlinx.coroutines.DispatchedTask.run(DispatchedTask.kt:100)
	at kotlinx.coroutines.internal.LimitedDispatcher$Worker.run(LimitedDispatcher.kt:124)
	at kotlinx.coroutines.scheduling.TaskImpl.run(Tasks.kt:89)
	at kotlinx.coroutines.scheduling.CoroutineScheduler.runSafely(CoroutineScheduler.kt:586)
	at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.executeTask(CoroutineScheduler.kt:820)
	at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.runWorker(CoroutineScheduler.kt:717)
	at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.run(CoroutineScheduler.kt:704)
2025-11-06 03:41:01 destination ERROR DefaultDispatcher-worker-4 i.a.c.l.t.DestinationTaskLauncher$WrappedTask(execute):129 Caught exception in task io.airbyte.cdk.load.task.implementor.OpenStreamTask@7e44ef93 java.lang.IllegalArgumentException: No enum constant io.airbyte.integrations.destination.mssql.v2.convert.MssqlType.UNIQUEIDENTIFIER
	at java.base/java.lang.Enum.valueOf(Enum.java:293) ~[?:?]
	at io.airbyte.integrations.destination.mssql.v2.convert.MssqlType.valueOf(AirbyteTypeToMssqlType.kt) ~[io.airbyte.airbyte-integrations.connectors-destination-mssql.jar:?]
	at io.airbyte.integrations.destination.mssql.v2.MSSQLQueryBuilder$getExistingSchema$1.invoke(MSSQLQueryBuilder.kt:253) ~[io.airbyte.airbyte-integrations.connectors-destination-mssql.jar:?]
	at io.airbyte.integrations.destination.mssql.v2.MSSQLQueryBuilder$getExistingSchema$1.invoke(MSSQLQueryBuilder.kt:250) ~[io.airbyte.airbyte-integrations.connectors-destination-mssql.jar:?]
	at io.airbyte.integrations.destination.mssql.v2.MSSQLQueryBuilderKt.executeQuery(MSSQLQueryBuilder.kt:66) ~[io.airbyte.airbyte-integrations.connectors-destination-mssql.jar:?]
	at io.airbyte.integrations.destination.mssql.v2.MSSQLQueryBuilder.getExistingSchema(MSSQLQueryBuilder.kt:250) ~[io.airbyte.airbyte-integrations.connectors-destination-mssql.jar:?]
	at io.airbyte.integrations.destination.mssql.v2.MSSQLQueryBuilder.updateSchema(MSSQLQueryBuilder.kt:264) ~[io.airbyte.airbyte-integrations.connectors-destination-mssql.jar:?]
	at io.airbyte.integrations.destination.mssql.v2.AbstractMSSQLStreamLoader.ensureTableExists(AbstractMSSQLStreamLoader.kt:48) ~[io.airbyte.airbyte-integrations.connectors-destination-mssql.jar:?]
	at io.airbyte.integrations.destination.mssql.v2.AbstractMSSQLStreamLoader.start$suspendImpl(AbstractMSSQLStreamLoader.kt:28) ~[io.airbyte.airbyte-integrations.connectors-destination-mssql.jar:?]
	at io.airbyte.integrations.destination.mssql.v2.AbstractMSSQLStreamLoader.start(AbstractMSSQLStreamLoader.kt) ~[io.airbyte.airbyte-integrations.connectors-destination-mssql.jar:?]
	at io.airbyte.integrations.destination.mssql.v2.MSSQLStreamLoader.start(MSSQLStreamLoader.kt:19) ~[io.airbyte.airbyte-integrations.connectors-destination-mssql.jar:?]
	at io.airbyte.cdk.load.task.implementor.OpenStreamTask$execute$2.emit(OpenStreamTask.kt:43) ~[bulk-cdk-core-load-0.1.61.jar:?]
	at io.airbyte.cdk.load.task.implementor.OpenStreamTask$execute$2.emit(OpenStreamTask.kt:36) ~[bulk-cdk-core-load-0.1.61.jar:?]
	at kotlinx.coroutines.flow.FlowKt__ChannelsKt.emitAllImpl$FlowKt__ChannelsKt(Channels.kt:33) ~[kotlinx-coroutines-core-jvm-1.10.2.jar:?]
	at kotlinx.coroutines.flow.FlowKt__ChannelsKt.access$emitAllImpl$FlowKt__ChannelsKt(Channels.kt:1) ~[kotlinx-coroutines-core-jvm-1.10.2.jar:?]
	at kotlinx.coroutines.flow.FlowKt__ChannelsKt$emitAllImpl$1.invokeSuspend(Channels.kt) ~[kotlinx-coroutines-core-jvm-1.10.2.jar:?]
	at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33) [kotlin-stdlib-2.1.10.jar:2.1.10-release-473]
	at kotlinx.coroutines.DispatchedTask.run(DispatchedTask.kt:100) [kotlinx-coroutines-core-jvm-1.10.2.jar:?]
	at kotlinx.coroutines.internal.LimitedDispatcher$Worker.run(LimitedDispatcher.kt:124) [kotlinx-coroutines-core-jvm-1.10.2.jar:?]
	at kotlinx.coroutines.scheduling.TaskImpl.run(Tasks.kt:89) [kotlinx-coroutines-core-jvm-1.10.2.jar:?]
	at kotlinx.coroutines.scheduling.CoroutineScheduler.runSafely(CoroutineScheduler.kt:586) [kotlinx-coroutines-core-jvm-1.10.2.jar:?]
	at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.executeTask(CoroutineScheduler.kt:820) [kotlinx-coroutines-core-jvm-1.10.2.jar:?]
	at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.runWorker(CoroutineScheduler.kt:717) [kotlinx-coroutines-core-jvm-1.10.2.jar:?]
	at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.run(CoroutineScheduler.kt:704) [kotlinx-coroutines-core-jvm-1.10.2.jar:?]

Stack Trace: java.lang.IllegalArgumentException: No enum constant io.airbyte.integrations.destination.mssql.v2.convert.MssqlType.UNIQUEIDENTIFIER
	at java.base/java.lang.Enum.valueOf(Enum.java:293)
	at io.airbyte.integrations.destination.mssql.v2.convert.MssqlType.valueOf(AirbyteTypeToMssqlType.kt)
	at io.airbyte.integrations.destination.mssql.v2.MSSQLQueryBuilder$getExistingSchema$1.invoke(MSSQLQueryBuilder.kt:253)
	at io.airbyte.integrations.destination.mssql.v2.MSSQLQueryBuilder$getExistingSchema$1.invoke(MSSQLQueryBuilder.kt:250)
	at io.airbyte.integrations.destination.mssql.v2.MSSQLQueryBuilderKt.executeQuery(MSSQLQueryBuilder.kt:66)
	at io.airbyte.integrations.destination.mssql.v2.MSSQLQueryBuilder.getExistingSchema(MSSQLQueryBuilder.kt:250)
	at io.airbyte.integrations.destination.mssql.v2.MSSQLQueryBuilder.updateSchema(MSSQLQueryBuilder.kt:264)
	at io.airbyte.integrations.destination.mssql.v2.AbstractMSSQLStreamLoader.ensureTableExists(AbstractMSSQLStreamLoader.kt:48)
	at io.airbyte.integrations.destination.mssql.v2.AbstractMSSQLStreamLoader.start$suspendImpl(AbstractMSSQLStreamLoader.kt:28)
	at io.airbyte.integrations.destination.mssql.v2.AbstractMSSQLStreamLoader.start(AbstractMSSQLStreamLoader.kt)
	at io.airbyte.integrations.destination.mssql.v2.MSSQLStreamLoader.start(MSSQLStreamLoader.kt:19)
	at io.airbyte.cdk.load.task.implementor.OpenStreamTask$execute$2.emit(OpenStreamTask.kt:43)
	at io.airbyte.cdk.load.task.implementor.OpenStreamTask$execute$2.emit(OpenStreamTask.kt:36)
	at kotlinx.coroutines.flow.FlowKt__ChannelsKt.emitAllImpl$FlowKt__ChannelsKt(Channels.kt:33)
	at kotlinx.coroutines.flow.FlowKt__ChannelsKt.access$emitAllImpl$FlowKt__ChannelsKt(Channels.kt:1)
	at kotlinx.coroutines.flow.FlowKt__ChannelsKt$emitAllImpl$1.invokeSuspend(Channels.kt)
	at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33)
	at kotlinx.coroutines.DispatchedTask.run(DispatchedTask.kt:100)
	at kotlinx.coroutines.internal.LimitedDispatcher$Worker.run(LimitedDispatcher.kt:124)
	at kotlinx.coroutines.scheduling.TaskImpl.run(Tasks.kt:89)
	at kotlinx.coroutines.scheduling.CoroutineScheduler.runSafely(CoroutineScheduler.kt:586)
	at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.executeTask(CoroutineScheduler.kt:820)
	at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.runWorker(CoroutineScheduler.kt:717)
	at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.run(CoroutineScheduler.kt:704)
2025-11-06 03:41:01 destination INFO DefaultDispatcher-worker-3 i.a.c.l.t.TaskScopeProvider$launch$job$1(invokeSuspend):34 Launching io.airbyte.cdk.load.task.implementor.FailStreamTask@182bfb2e
2025-11-06 03:41:01 destination WARN DefaultDispatcher-worker-3 i.a.c.l.t.i.FailStreamTask(execute):46 StreamLoader not found for stream Descriptor(namespace=null, name=SLATE_application), cannot call close.
2025-11-06 03:41:01 destination INFO DefaultDispatcher-worker-3 i.a.c.l.t.TaskScopeProvider$launch$job$1(invokeSuspend):36 Task io.airbyte.cdk.load.task.implementor.FailStreamTask@182bfb2e completed

Contribute

  • Yes, I want to contribute

Metadata

Metadata

Assignees

No one assigned

    Labels

    area/connectorsConnector related issuesautoteamcommunityneeds-triageteam/extensibilityteam/usetype/bugSomething isn't working

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions