airbytehq / airbytehq/airbyte

MS SQL destination connector doesn't understand UNIQUEIDENTIFIER field type

Đang mở
#69,224 0 bình luận 0 reaction 0 người được giao Xem trên GitHub
area/connectors autoteam community connectors/destination/mssql needs-triage team/extensibility team/use type/bug
Ngôn ngữ chính
Python
Star
22.1k
Fork
5.3k
Chỉ số pull request đang chờ

Mô tả

### 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

```shell
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

Hướng dẫn đóng góp

Mở hướng dẫn đóng góp

Đánh giá

Issue này chưa được đánh giá.

Nhận issue mới trong hộp thư của bạn

Bản tóm tắt ngắn những issue GitHub phù hợp với người mới.