Replication hangs indefinitely when destination crashes during socket data channel initialization

### Helm Chart Version

2.1.0

### What step the error happened?

During the Sync

### Relevant information

A CDC sync from MySQL → ClickHouse hung for 21 hours in RUNNING state without transferring any data, until it was cancelled manually.

Root cause visible in the logs is a startup race condition in the Unix domain socket data channel:

1. `12:40:46` — Source starts initializing the 4 sockets under `/var/run/sockets/`. Socket 1 connects; sockets 2–4 are still in `Waiting to connect...`.
2. `12:40:47` — Destination calls `ClientSocket.openInputStream` on a socket whose listener is not yet ready and crashes **one second after start**:

```
io.airbyte.cdk.ConfigErrorException: Failed to initialize connector operation
Caused by: io.micronaut.context.exceptions.BeanInstantiationException
Caused by: java.net.ConnectException: Connection refused
at io.airbyte.cdk.load.file.ClientSocket.openInputStream(ClientSocket.kt:45)
at io.airbyte.cdk.load.dataflow.config.InputBeanFactory.socketStreams(InputBeanFactory.kt:86)
```

3. `12:40:48` onwards — The source never notices the destination is gone. It proceeds normally (table discovery, cold start offset generation, streams transition to RUNNING) and then blocks forever writing to sockets nobody reads. For the next 21 hours it only logs its coroutine state every ~30s:

```
read
└─global
├─global-round-1-partition-1-acquire-resources
└─global-round-1-partition-1-read
```

4. The workload heartbeat (`interval=10s; timeout=600s`) is emitted by the orchestrator, which stayed alive — so the platform considered the workload healthy and no timeout ever fired. The job ended only after a manual cancel (`Workload in terminal state; exiting`).

### Relevant log output

```shell
2026-07-13 12:40:46 info INFO main i.a.c.o.s.UnixDomainSocketDataChannel$initialize$2(invokeSuspend):98 Initializing socket at /var/run/sockets/airbyte_socket_1.sock
2026-07-13 12:40:46 info INFO main i.a.c.l.d.c.InputBeanFactory(sockets):68 Using all 4 sockets provided by platform
2026-07-13 12:40:46 info INFO main i.a.c.l.f.ClientSocket(openInputStream):24 Connecting client socket at /var/run/sockets/airbyte_socket_1.sock
2026-07-13 12:40:46 info INFO main i.a.c.l.f.ClientSocket(openInputStream):38 Socket file /var/run/sockets/airbyte_socket_1.sock created
2026-07-13 12:40:46 info INFO main i.a.c.l.f.ClientSocket(openInputStream):43 Socket file /var/run/sockets/airbyte_socket_1.sock opened
2026-07-13 12:40:46 info INFO main i.a.c.o.s.UnixDomainSocketDataChannel$initialize$2(invokeSuspend):98 Initializing socket at /var/run/sockets/airbyte_socket_2.sock
2026-07-13 12:40:46 info INFO DefaultDispatcher-worker-2#socket-data-channel-/var/run/sockets/airbyte_socket_2.sock-- i.a.c.o.s.UnixDomainSocketDataChannel$initialize$2$2(invokeSuspend):119 Waiting to connect...
2026-07-13 12:40:46 info INFO DefaultDispatcher-worker-1#socket-data-channel-/var/run/sockets/airbyte_socket_1.sock-- i.a.c.o.s.UnixDomainSocketDataChannel$initialize$2$2(invokeSuspend):119 Waiting to connect...
2026-07-13 12:40:46 info INFO main i.a.c.o.s.UnixDomainSocketDataChannel$initialize$2(invokeSuspend):98 Initializing socket at /var/run/sockets/airbyte_socket_3.sock
2026-07-13 12:40:46 info INFO main i.a.c.o.s.UnixDomainSocketDataChannel$initialize$2(invokeSuspend):98 Initializing socket at /var/run/sockets/airbyte_socket_4.sock
2026-07-13 12:40:46 info INFO DefaultDispatcher-worker-4#socket-data-channel-/var/run/sockets/airbyte_socket_3.sock-- i.a.c.o.s.UnixDomainSocketDataChannel$initialize$2$2(invokeSuspend):119 Waiting to connect...
2026-07-13 12:40:46 info INFO DefaultDispatcher-worker-3#socket-data-channel-/var/run/sockets/airbyte_socket_4.sock-- i.a.c.o.s.UnixDomainSocketDataChannel$initialize$2$2(invokeSuspend):119 Waiting to connect...
2026-07-13 12:40:46 info INFO main i.a.i.s.m.MySqlSourceConfigurationFactory(makeWithoutExceptionHandling):143 SSL mode: required
2026-07-13 12:40:46 info INFO main i.a.i.s.m.MySqlSourceConfigurationFactory(makeWithoutExceptionHandling):188 maxConcurrencyLegacy: 1. maxDBConnections: null. socket paths: 4
2026-07-13 12:40:46 info INFO main i.a.i.s.m.MySqlSourceConfigurationFactory(makeWithoutExceptionHandling):207 Effective concurrency: 4
2026-07-13 12:40:46 info INFO main i.a.i.s.m.MySqlSourceConfigurationFactory(makeWithoutExceptionHandling):143 SSL mode: required
2026-07-13 12:40:46 info INFO main i.a.i.s.m.MySqlSourceConfigurationFactory(makeWithoutExceptionHandling):188 maxConcurrencyLegacy: 1. maxDBConnections: null. socket paths: 4
2026-07-13 12:40:46 info INFO main i.a.i.s.m.MySqlSourceConfigurationFactory(makeWithoutExceptionHandling):207 Effective concurrency: 4
2026-07-13 12:40:46 info INFO main i.a.c.AirbyteConnectorRunnable(run):35 Executing class io.airbyte.cdk.read.ReadOperation operation.
2026-07-13 12:40:46 info INFO main i.a.c.j.JdbcConnectionFactory(get):44 Creating new connection for 'jdbc:mysql://192.168.230.24:3307'.
2026-07-13 12:40:46 error ERROR main i.a.c.AirbyteConnectorRunnable(run):38 Failed connector operation initialization. io.airbyte.cdk.ConfigErrorException: Failed to initialize connector operation
at io.airbyte.cdk.AirbyteConnectorRunnable.run(AirbyteConnectorRunnable.kt:33) [bulk-cdk-core-base-1.0.3.jar:?]
at picocli.CommandLine.executeUserObject(CommandLine.java:2030) [picocli-4.7.6.jar:4.7.6]
at picocli.CommandLine.access$1500(CommandLine.java:148) [picocli-4.7.6.jar:4.7.6]
at picocli.CommandLine$RunLast.executeUserObjectOfLastSubcommandWithSameParent(CommandLine.java:2465) [picocli-4.7.6.jar:4.7.6]
at picocli.CommandLine$RunLast.handle(CommandLine.java:2457) [picocli-4.7.6.jar:4.7.6]
at picocli.CommandLine$RunLast.handle(CommandLine.java:2419) [picocli-4.7.6.jar:4.7.6]
at picocli.CommandLine$AbstractParseResultHandler.execute(CommandLine.java:2277) [picocli-4.7.6.jar:4.7.6]
at picocli.CommandLine$RunLast.execute(CommandLine.java:2421) [picocli-4.7.6.jar:4.7.6]
at picocli.CommandLine.execute(CommandLine.java:2174) [picocli-4.7.6.jar:4.7.6]
at io.airbyte.cdk.AirbyteDestinationRunner$Companion.run(AirbyteConnectorRunner.kt:289) [bulk-cdk-core-base-1.0.3.jar:?]
at io.airbyte.cdk.AirbyteDestinationRunner$Companion.run$default(AirbyteConnectorRunner.kt:75) [bulk-cdk-core-base-1.0.3.jar:?]
at io.airbyte.integrations.destination.clickhouse.ClickhouseDestinationKt.main(ClickhouseDestination.kt:10) [io.airbyte.airbyte-integrations.connectors-destination-clickhouse.jar:?]
Caused by: io.micronaut.context.exceptions.BeanInstantiationException: Error instantiating bean of type [java.util.List]

Message: Connection refused
Path Taken: new WriteOperation(DestinationLifecycle destinationLifecycle) --> new WriteOperation([DestinationLifecycle destinationLifecycle]) --> new DestinationLifecycle(DestinationWriter destinationInitializer,DestinationCatalog destinationCatalog,[PipelineRunner pipeline],StreamCompletionTracker completionTracker,CoroutineDispatcher streamInitDispatcher,CoroutineDispatcher streamFinalizeDispatcher) --> new PipelineRunner(StateReconciler reconciler,StateStore store,[List pipelines],ConnectorInputStreams inputStreams,CoroutineScope pipelineScope,CoroutineDispatcher aggregationDispatcher) --> InputBeanFactory.pipes([List inputFlows],DataFlowStage parse,DataFlowStage flush,DataFlowStage state,AggregateStoreFactory aggregateStoreFactory,StateHistogramStore stateHistogramStore,CommittedStatsStore statsStore,AggregatePublishingConfig aggregatePublishingConfig,CoroutineDispatcher aggregationDispatcher,CoroutineDispatcher flushDispatcher,CoroutineDispatcher finalFlushDispatcher) --> InputBeanFactory.inputFlows([List E> messageFlows],StateStore stateStore,StateKeyClient stateKeyClient,StreamCompletionTracker completionTracker,EmittedStatsStore statsStore) --> InputBeanFactory.messageFlows([ConnectorInputStreams inputStreams],DataChannelFormat dataChannelFormat,ProtocolMessageDeserializer deserializer,DestinationMessageFactory destinationMessageFactory)
at io.micronaut.context.DefaultBeanContext.resolveByBeanFactory(DefaultBeanContext.java:2341) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.doCreateBean(DefaultBeanContext.java:2296) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.doCreateBean(DefaultBeanContext.java:2308) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.createRegistration(DefaultBeanContext.java:3118) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.SingletonScope.getOrCreate(SingletonScope.java:80) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.findOrCreateSingletonBeanRegistration(DefaultBeanContext.java:3020) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.resolveBeanRegistration(DefaultBeanContext.java:2981) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.resolveBeanRegistration(DefaultBeanContext.java:2747) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.getBean(DefaultBeanContext.java:1745) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.AbstractBeanResolutionContext.getBean(AbstractBeanResolutionContext.java:89) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.AbstractInitializableBeanDefinition.resolveBean(AbstractInitializableBeanDefinition.java:2188) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.AbstractInitializableBeanDefinition.getBeanForConstructorArgument(AbstractInitializableBeanDefinition.java:1350) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.airbyte.cdk.load.dataflow.config.$InputBeanFactory$MessageFlows3$Definition.instantiate(Unknown Source) ~[bulk-cdk-core-load-1.0.13.jar:?]
at io.micronaut.context.DefaultBeanContext.resolveByBeanFactory(DefaultBeanContext.java:2326) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.doCreateBean(DefaultBeanContext.java:2296) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.doCreateBean(DefaultBeanContext.java:2308) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.createRegistration(DefaultBeanContext.java:3118) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.SingletonScope.getOrCreate(SingletonScope.java:80) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.findOrCreateSingletonBeanRegistration(DefaultBeanContext.java:3020) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.resolveBeanRegistration(DefaultBeanContext.java:2981) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.resolveBeanRegistration(DefaultBeanContext.java:2954) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.addCandidateToList(DefaultBeanContext.java:3572) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.resolveBeanRegistrations(DefaultBeanContext.java:3527) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.getBeanRegistrations(DefaultBeanContext.java:3501) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.getBeansOfType(DefaultBeanContext.java:1446) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.AbstractBeanResolutionContext.getBeansOfType(AbstractBeanResolutionContext.java:95) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.AbstractInitializableBeanDefinition.resolveBeansOfType(AbstractInitializableBeanDefinition.java:2276) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.AbstractInitializableBeanDefinition.getBeansOfTypeForConstructorArgument(AbstractInitializableBeanDefinition.java:1498) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.airbyte.cdk.load.dataflow.config.$InputBeanFactory$InputFlows4$Definition.instantiate(Unknown Source) ~[bulk-cdk-core-load-1.0.13.jar:?]
at io.micronaut.context.DefaultBeanContext.resolveByBeanFactory(DefaultBeanContext.java:2326) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.doCreateBean(DefaultBeanContext.java:2296) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.doCreateBean(DefaultBeanContext.java:2308) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.createRegistration(DefaultBeanContext.java:3118) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.SingletonScope.getOrCreate(SingletonScope.java:80) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.findOrCreateSingletonBeanRegistration(DefaultBeanContext.java:3020) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.resolveBeanRegistration(DefaultBeanContext.java:2981) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.resolveBeanRegistration(DefaultBeanContext.java:2954) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.addCandidateToList(DefaultBeanContext.java:3572) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.resolveBeanRegistrations(DefaultBeanContext.java:3527) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.getBeanRegistrations(DefaultBeanContext.java:3501) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.getBeansOfType(DefaultBeanContext.java:1446) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.AbstractBeanResolutionContext.getBeansOfType(AbstractBeanResolutionContext.java:95) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.AbstractInitializableBeanDefinition.resolveBeansOfType(AbstractInitializableBeanDefinition.java:2276) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.AbstractInitializableBeanDefinition.getBeansOfTypeForConstructorArgument(AbstractInitializableBeanDefinition.java:1498) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.airbyte.cdk.load.dataflow.config.$InputBeanFactory$Pipes6$Definition.instantiate(Unknown Source) ~[bulk-cdk-core-load-1.0.13.jar:?]
at io.micronaut.context.DefaultBeanContext.resolveByBeanFactory(DefaultBeanContext.java:2326) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.doCreateBean(DefaultBeanContext.java:2296) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.doCreateBean(DefaultBeanContext.java:2308) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.createRegistration(DefaultBeanContext.java:3118) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.SingletonScope.getOrCreate(SingletonScope.java:80) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.findOrCreateSingletonBeanRegistration(DefaultBeanContext.java:3020) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.resolveBeanRegistration(DefaultBeanContext.java:2981) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.resolveBeanRegistration(DefaultBeanContext.java:2954) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.addCandidateToList(DefaultBeanContext.java:3572) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.resolveBeanRegistrations(DefaultBeanContext.java:3527) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.getBeanRegistrations(DefaultBeanContext.java:3501) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.getBeansOfType(DefaultBeanContext.java:1446) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.AbstractBeanResolutionContext.getBeansOfType(AbstractBeanResolutionContext.java:95) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.AbstractInitializableBeanDefinition.resolveBeansOfType(AbstractInitializableBeanDefinition.java:2276) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.AbstractInitializableBeanDefinition.getBeansOfTypeForConstructorArgument(AbstractInitializableBeanDefinition.java:1498) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.airbyte.cdk.load.dataflow.pipeline.$PipelineRunner$Definition.instantiate(Unknown Source) ~[bulk-cdk-core-load-1.0.13.jar:?]
at io.micronaut.context.DefaultBeanContext.resolveByBeanFactory(DefaultBeanContext.java:2326) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.doCreateBean(DefaultBeanContext.java:2296) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.doCreateBean(DefaultBeanContext.java:2308) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.createRegistration(DefaultBeanContext.java:3118) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.SingletonScope.getOrCreate(SingletonScope.java:80) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.findOrCreateSingletonBeanRegistration(DefaultBeanContext.java:3020) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.resolveBeanRegistration(DefaultBeanContext.java:2981) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.resolveBeanRegistration(DefaultBeanContext.java:2747) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.getBean(DefaultBeanContext.java:1745) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.AbstractBeanResolutionContext.getBean(AbstractBeanResolutionContext.java:89) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.AbstractInitializableBeanDefinition.resolveBean(AbstractInitializableBeanDefinition.java:2188) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.AbstractInitializableBeanDefinition.getBeanForConstructorArgument(AbstractInitializableBeanDefinition.java:1350) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.airbyte.cdk.load.dataflow.$DestinationLifecycle$Definition.instantiate(Unknown Source) ~[bulk-cdk-core-load-1.0.13.jar:?]
at io.micronaut.context.DefaultBeanContext.resolveByBeanFactory(DefaultBeanContext.java:2326) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.doCreateBean(DefaultBeanContext.java:2296) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.doCreateBean(DefaultBeanContext.java:2308) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.createRegistration(DefaultBeanContext.java:3118) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.SingletonScope.getOrCreate(SingletonScope.java:80) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.findOrCreateSingletonBeanRegistration(DefaultBeanContext.java:3020) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.resolveBeanRegistration(DefaultBeanContext.java:2981) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.resolveBeanRegistration(DefaultBeanContext.java:2747) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.getBean(DefaultBeanContext.java:1745) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.AbstractBeanResolutionContext.getBean(AbstractBeanResolutionContext.java:89) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.AbstractInitializableBeanDefinition.resolveBean(AbstractInitializableBeanDefinition.java:2188) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.AbstractInitializableBeanDefinition.getBeanForConstructorArgument(AbstractInitializableBeanDefinition.java:1350) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.airbyte.cdk.load.write.$WriteOperation$Definition.instantiate(Unknown Source) ~[bulk-cdk-core-load-1.0.13.jar:?]
at io.micronaut.context.DefaultBeanContext.resolveByBeanFactory(DefaultBeanContext.java:2326) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.doCreateBean(DefaultBeanContext.java:2296) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.doCreateBean(DefaultBeanContext.java:2308) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.createRegistration(DefaultBeanContext.java:3118) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.SingletonScope.getOrCreate(SingletonScope.java:80) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.findOrCreateSingletonBeanRegistration(DefaultBeanContext.java:3020) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.resolveBeanRegistration(DefaultBeanContext.java:2981) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.resolveBeanRegistration(DefaultBeanContext.java:2747) ~[micronaut-inject-4.6.1.jar:4.6.1]
at io.micronaut.context.DefaultBeanContext.getBean(DefaultBeanContext.java:1745) ~[micronaut-in…
Stack Trace: io.airbyte.cdk.ConfigErrorException: Failed to initialize connector operation
at io.airbyte.cdk.AirbyteConnectorRunnable.run(AirbyteConnectorRunnable.kt:33)
at picocli.CommandLine.executeUserObject(CommandLine.java:2030)
at picocli.CommandLine.access$1500(CommandLine.java:148)
at picocli.CommandLine$RunLast.executeUserObjectOfLastSubcommandWithSameParent(CommandLine.java:2465)
at picocli.CommandLine$RunLast.handle(CommandLine.java:2457)
at picocli.CommandLine$RunLast.handle(CommandLine.java:2419)
at picocli.CommandLine$AbstractParseResultHandler.execute(CommandLine.java:2277)
at picocli.CommandLine$RunLast.execute(CommandLine.java:2421)
at picocli.CommandLine.execute(CommandLine.java:2174)
at io.airbyte.cdk.AirbyteDestinationRunner$Companion.run(AirbyteConnectorRunner.kt:289)
at io.airbyte.cdk.AirbyteDestinationRunner$Companion.run$default(AirbyteConnectorRunner.kt:75)
at io.airbyte.integrations.destination.clickhouse.ClickhouseDestinationKt.main(ClickhouseDestination.kt:10)
Caused by: io.micronaut.context.exceptions.BeanInstantiationException: Error instantiating bean of type [java.util.List]

Message: Connection refused
Path Taken: new WriteOperation(DestinationLifecycle destinationLifecycle) --> new WriteOperation([DestinationLifecycle destinationLifecycle]) --> new DestinationLifecycle(DestinationWriter destinationInitializer,DestinationCatalog destinationCatalog,[PipelineRunner pipeline],StreamCompletionTracker completionTracker,CoroutineDispatcher streamInitDispatcher,CoroutineDispatcher streamFinalizeDispatcher) --> new PipelineRunner(StateReconciler reconciler,StateStore store,[List pipelines],ConnectorInputStreams inputStreams,CoroutineScope pipelineScope,CoroutineDispatcher aggregationDispatcher) --> InputBeanFactory.pipes([List inputFlows],DataFlowStage parse,DataFlowStage flush,DataFlowStage state,AggregateStoreFactory aggregateStoreFactory,StateHistogramStore stateHistogramStore,CommittedStatsStore statsStore,AggregatePublishingConfig aggregatePublishingConfig,CoroutineDispatcher aggregationDispatcher,CoroutineDispatcher flushDispatcher,CoroutineDispatcher finalFlushDispatcher) --> InputBeanFactory.inputFlows([List E> messageFlows],StateStore stateStore,StateKeyClient stateKeyClient,StreamCompletionTracker completionTracker,EmittedStatsStore statsStore) --> InputBeanFactory.messageFlows([ConnectorInputStreams inputStreams],DataChannelFormat dataChannelFormat,ProtocolMessageDeserializer deserializer,DestinationMessageFactory destinationMessageFactory)
at io.micronaut.context.DefaultBeanContext.resolveByBeanFactory(DefaultBeanContext.java:2341)
at io.micronaut.context.DefaultBeanContext.doCreateBean(DefaultBeanContext.java:2296)
at io.micronaut.context.DefaultBeanContext.doCreateBean(DefaultBeanContext.java:2308)
at io.micronaut.context.DefaultBeanContext.createRegistration(DefaultBeanContext.java:3118)
at io.micronaut.context.SingletonScope.getOrCreate(SingletonScope.java:80)
at io.micronaut.context.DefaultBeanContext.findOrCreateSingletonBeanRegistration(DefaultBeanContext.java:3020)
at io.micronaut.context.DefaultBeanContext.resolveBeanRegistration(DefaultBeanContext.java:2981)
at io.micronaut.context.DefaultBeanContext.resolveBeanRegistration(DefaultBeanContext.java:2747)
at io.micronaut.context.DefaultBeanContext.getBean(DefaultBeanContext.java:1745)
at io.micronaut.context.AbstractBeanResolutionContext.getBean(AbstractBeanResolutionContext.java:89)
at io.micronaut.context.AbstractInitializableBeanDefinition.resolveBean(AbstractInitializableBeanDefinition.java:2188)
at io.micronaut.context.AbstractInitializableBeanDefinition.getBeanForConstructorArgument(AbstractInitializableBeanDefinition.java:1350)
at io.airbyte.cdk.load.dataflow.config.$InputBeanFactory$MessageFlows3$Definition.instantiate(Unknown Source)
at io.micronaut.context.DefaultBeanContext.resolveByBeanFactory(DefaultBeanContext.java:2326)
at io.micronaut.context.DefaultBeanContext.doCreateBean(DefaultBeanContext.java:2296)
at io.micronaut.context.DefaultBeanContext.doCreateBean(DefaultBeanContext.java:2308)
at io.micronaut.context.DefaultBeanContext.createRegistration(DefaultBeanContext.java:3118)
at io.micronaut.context.SingletonScope.getOrCreate(SingletonScope.java:80)
at io.micronaut.context.DefaultBeanContext.findOrCreateSingletonBeanRegistration(DefaultBeanContext.java:3020)
at io.micronaut.context.DefaultBeanContext.resolveBeanRegistration(DefaultBeanContext.java:2981)
at io.micronaut.context.DefaultBeanContext.resolveBeanRegistration(DefaultBeanContext.java:2954)
at io.micronaut.context.DefaultBeanContext.addCandidateToList(DefaultBeanContext.java:3572)
at io.micronaut.context.DefaultBeanContext.resolveBeanRegistrations(DefaultBeanContext.java:3527)
at io.micronaut.context.DefaultBeanContext.getBeanRegistrations(DefaultBeanContext.java:3501)
at io.micronaut.context.DefaultBeanContext.getBeansOfType(DefaultBeanContext.java:1446)
at io.micronaut.context.AbstractBeanResolutionContext.getBeansOfType(AbstractBeanResolutionContext.java:95)
at io.micronaut.context.AbstractInitializableBeanDefinition.resolveBeansOfType(AbstractInitializableBeanDefinition.java:2276)
at io.micronaut.context.AbstractInitializableBeanDefinition.getBeansOfTypeForConstructorArgument(AbstractInitializableBeanDefinition.java:1498)
at io.airbyte.cdk.load.dataflow.config.$InputBeanFactory$InputFlows4$Definition.instantiate(Unknown Source)
at io.micronaut.context.DefaultBeanContext.resolveByBeanFactory(DefaultBeanContext.java:2326)
at io.micronaut.context.DefaultBeanContext.doCreateBean(DefaultBeanContext.java:2296)
at io.micronaut.context.DefaultBeanContext.doCreateBean(DefaultBeanContext.java:2308)
at io.micronaut.context.DefaultBeanContext.createRegistration(DefaultBeanContext.java:3118)
at io.micronaut.context.SingletonScope.getOrCreate(SingletonScope.java:80)
at io.micronaut.context.DefaultBeanContext.findOrCreateSingletonBeanRegistration(DefaultBeanContext.java:3020)
at io.micronaut.context.DefaultBeanContext.resolveBeanRegistration(DefaultBeanContext.java:2981)
at io.micronaut.context.DefaultBeanContext.resolveBeanRegistration(DefaultBeanContext.java:2954)
at io.micronaut.context.DefaultBeanContext.addCandidateToList(DefaultBeanContext.java:3572)
at io.micronaut.context.DefaultBeanContext.resolveBeanRegistrations(DefaultBeanContext.java:3527)
at io.micronaut.context.DefaultBeanContext.getBeanRegistrations(DefaultBeanContext.java:3501)
at io.micronaut.context.DefaultBeanContext.getBeansOfType(DefaultBeanContext.java:1446)
at io.micronaut.context.AbstractBeanResolutionContext.getBeansOfType(AbstractBeanResolutionContext.java:95)
at io.micronaut.context.AbstractInitializableBeanDefinition.resolveBeansOfType(AbstractInitializableBeanDefinition.java:2276)
at io.micronaut.context.AbstractInitializableBeanDefinition.getBeansOfTypeForConstructorArgument(AbstractInitializableBeanDefinition.java:1498)
at io.airbyte.cdk.load.dataflow.config.$InputBeanFactory$Pipes6$Definition.instantiate(Unknown Source)
at io.micronaut.context.DefaultBeanContext.resolveByBeanFactory(DefaultBeanContext.java:2326)
at io.micronaut.context.DefaultBeanContext.doCreateBean(DefaultBeanContext.java:2296)
at io.micronaut.context.DefaultBeanContext.doCreateBean(DefaultBeanContext.java:2308)
at io.micronaut.context.DefaultBeanContext.createRegistration(DefaultBeanContext.java:3118)
at io.micronaut.context.SingletonScope.getOrCreate(SingletonScope.java:80)
at io.micronaut.context.DefaultBeanContext.findOrCreateSingletonBeanRegistration(DefaultBeanContext.java:3020)
at io.micronaut.context.DefaultBeanContext.resolveBeanRegistration(DefaultBeanContext.java:2981)
at io.micronaut.context.DefaultBeanContext.resolveBeanRegistration(DefaultBeanContext.java:2954)
at io.micronaut.context.DefaultBeanContext.addCandidateToList(DefaultBeanContext.java:3572)
at io.micronaut.context.DefaultBeanContext.resolveBeanRegistrations(DefaultBeanContext.java:3527)
at io.micronaut.context.DefaultBeanContext.getBeanRegistrations(DefaultBeanContext.java:3501)
at io.micronaut.context.DefaultBeanContext.getBeansOfType(DefaultBeanContext.java:1446)
at io.micronaut.context.AbstractBeanResolutionContext.getBeansOfType(AbstractBeanResolutionContext.java:95)
at io.micronaut.context.AbstractInitializableBeanDefinition.resolveBeansOfType(AbstractInitializableBeanDefinition.java:2276)
at io.micronaut.context.AbstractInitializableBeanDefinition.getBeansOfTypeForConstructorArgument(AbstractInitializableBeanDefinition.java:1498)
at io.airbyte.cdk.load.dataflow.pipeline.$PipelineRunner$Definition.instantiate(Unknown Source)
at io.micronaut.context.DefaultBeanContext.resolveByBeanFactory(DefaultBeanContext.java:2326)
at io.micronaut.context.DefaultBeanContext.doCreateBean(DefaultBeanContext.java:2296)
at io.micronaut.context.DefaultBeanContext.doCreateBean(DefaultBeanContext.java:2308)
at io.micronaut.context.DefaultBeanContext.createRegistration(DefaultBeanContext.java:3118)
at io.micronaut.context.SingletonScope.getOrCreate(SingletonScope.java:80)
at io.micronaut.context.DefaultBeanContext.findOrCreateSingletonBeanRegistration(DefaultBeanContext.java:3020)
at io.micronaut.context.DefaultBeanContext.resolveBeanRegistration(DefaultBeanContext.java:2981)
at io.micronaut.context.DefaultBeanContext.resolveBeanRegistration(DefaultBeanContext.java:2747)
at io.micronaut.context.DefaultBeanContext.getBean(DefaultBeanContext.java:1745)
at io.micronaut.context.AbstractBeanResolutionContext.getBean(AbstractBeanResolutionContext.java:89)
at io.micronaut.context.AbstractInitializableBeanDefinition.resolveBean(AbstractInitializableBeanDefinition.java:2188)
at io.micronaut.context.AbstractInitializableBeanDefinition.getBeanForConstructorArgument(AbstractInitializableBeanDefinition.java:1350)
at io.airbyte.cdk.load.dataflow.$DestinationLifecycle$Definition.instantiate(Unknown Source)
at io.micronaut.context.DefaultBeanContext.resolveByBeanFactory(DefaultBeanContext.java:2326)
at io.micronaut.context.DefaultBeanContext.doCreateBean(DefaultBeanContext.java:2296)
at io.micronaut.context.DefaultBeanContext.doCreateBean(DefaultBeanContext.java:2308)
at io.micronaut.context.DefaultBeanContext.createRegistration(DefaultBeanContext.java:3118)
at io.micronaut.context.SingletonScope.getOrCreate(SingletonScope.java:80)
at io.micronaut.context.DefaultBeanContext.findOrCreateSingletonBeanRegistration(DefaultBeanContext.java:3020)
at io.micronaut.context.DefaultBeanContext.resolveBeanRegistration(DefaultBeanContext.java:2981)
at io.micronaut.context.DefaultBeanContext.resolveBeanRegistration(DefaultBeanContext.java:2747)
at io.micronaut.context.DefaultBeanContext.getBean(DefaultBeanContext.java:1745)
at io.micronaut.context.AbstractBeanResolutionContext.getBean(AbstractBeanResolutionContext.java:89)
at io.micronaut.context.AbstractInitializableBeanDefinition.resolveBean(AbstractInitializableBeanDefinition.java:2188)
at io.micronaut.context.AbstractInitializableBeanDefinition.getBeanForConstructorArgument(AbstractInitializableBeanDefinition.java:1350)
at io.airbyte.cdk.load.write.$WriteOperation$Definition.instantiate(Unknown Source)
at io.micronaut.context.DefaultBeanContext.resolveByBeanFactory(DefaultBeanContext.java:2326)
at io.micronaut.context.DefaultBeanContext.doCreateBean(DefaultBeanContext.java:2296)
at io.micronaut.context.DefaultBeanContext.doCreateBean(DefaultBeanContext.java:2308)
at io.micronaut.context.DefaultBeanContext.createRegistration(DefaultBeanContext.java:3118)
at io.micronaut.context.SingletonScope.getOrCreate(SingletonScope.java:80)
at io.micronaut.context.DefaultBeanContext.findOrCreateSingletonBeanRegistration(DefaultBeanContext.java:3020)
at io.micronaut.context.DefaultBeanContext.resolveBeanRegistration(DefaultBeanContext.java:2981)
at io.micronaut.context.DefaultBeanContext.resolveBeanRegistration(DefaultBeanContext.java:2747)
at io.micronaut.context.DefaultBeanContext.getBean(DefaultBeanContext.java:1745)
at io.micronaut.inject.provider.JakartaProviderBeanDefinition.lambda$buildProvider$0(JakartaProviderBeanDefinition.java:65)
at io.airbyte.cdk.AirbyteConnectorRunnable.run(AirbyteConnectorRunnable.kt:31)
... 11 more
Caused by: java.net.ConnectException: Connection refused
at java.base/sun.nio.ch.UnixDomainSockets.connect0(Native Method)
at java.base/sun.nio.ch.UnixDomainSockets.connect(UnixDomainSockets.java:154)
at java.base/sun.nio.ch.UnixDomainSockets.connect(UnixDomainSockets.java:150)
at java.base/sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:878)
at io.airbyte.cdk.load.file.ClientSocket.openInputStream(ClientSocket.kt:45)
at io.airbyte.cdk.load.dataflow.config.InputBeanFactory.socketStreams(InputBeanFactory.kt:86)
at io.airbyte.cdk.load.dataflow.config.$InputBeanFactory$SocketStreams1$Definition.instantiate(Unknown Source)
at io.micronaut.context.DefaultBeanContext.resolveByBeanFactory(DefaultBeanContext.java:2326)
... 108 more

2026-07-13 12:40:47 info INFO main i.a.c.AirbyteConnectorRunnable(run):47 Flushing output consumer prior to shutdown.
2026-07-13 12:40:47 info INFO main i.a.c.AirbyteConnectorRunnable(run):49 Completed integration: airbyte/destination-clickhouse.
2026-07-13 12:40:47 error io.airbyte.cdk.ConfigErrorException: Failed to initialize connector operation
2026-07-13 12:40:47 error at io.airbyte.cdk.AirbyteConnectorRunnable.run(AirbyteConnectorRunnable.kt:33)
2026-07-13 12:40:47 error at picocli.CommandLine.executeUserObject(CommandLine.java:2030)
2026-07-13 12:40:47 error at picocli.CommandLine.access$1500(CommandLine.java:148)
2026-07-13 12:40:47 error at picocli.CommandLine$RunLast.executeUserObjectOfLastSubcommandWithSameParent(CommandLine.java:2465)
2026-07-13 12:40:47 error at picocli.CommandLine$RunLast.handle(CommandLine.java:2457)
2026-07-13 12:40:47 error at picocli.CommandLine$RunLast.handle(CommandLine.java:2419)
2026-07-13 12:40:47 error at picocli.CommandLine$AbstractParseResultHandler.execute(CommandLine.java:2277)
2026-07-13 12:40:47 error at picocli.CommandLine$RunLast.execute(CommandLine.java:2421)
2026-07-13 12:40:47 error at picocli.CommandLine.execute(CommandLine.java:2174)
2026-07-13 12:40:47 error at io.airbyte.cdk.AirbyteDestinationRunner$Companion.run(AirbyteConnectorRunner.kt:289)
2026-07-13 12:40:47 error at io.airbyte.cdk.AirbyteDestinationRunner$Companion.run$default(AirbyteConnectorRunner.kt:75)
2026-07-13 12:40:47 error at io.airbyte.integrations.destination.clickhouse.ClickhouseDestinationKt.main(ClickhouseDestination.kt:10)
2026-07-13 12:40:47 error Caused by: io.micronaut.context.exceptions.BeanInstantiationException: Error instantiating bean of type [java.util.List]
2026-07-13 12:40:47 error
2026-07-13 12:40:47 error Message: Connection refused
2026-07-13 12:40:47 error Path Taken: new WriteOperation(DestinationLifecycle destinationLifecycle) --> new WriteOperation([DestinationLifecycle destinationLifecycle]) --> new DestinationLifecycle(DestinationWriter destinationInitializer,DestinationCatalog destinationCatalog,[PipelineRunner pipeline],StreamCompletionTracker completionTracker,CoroutineDispatcher streamInitDispatcher,CoroutineDispatcher streamFinalizeDispatcher) --> new PipelineRunner(StateReconciler reconciler,StateStore store,[List pipelines],ConnectorInputStreams inputStreams,CoroutineScope pipelineScope,CoroutineDispatcher aggregationDispatcher) --> InputBeanFactory.pipes([List inputFlows],DataFlowStage parse,DataFlowStage flush,DataFlowStage state,AggregateStoreFactory aggregateStoreFactory,StateHistogramStore stateHistogramStore,CommittedStatsStore statsStore,AggregatePublishingConfig aggregatePublishingConfig,CoroutineDispatcher aggregationDispatcher,CoroutineDispatcher flushDispatcher,CoroutineDispatcher finalFlushDispatcher) --> InputBeanFactory.inputFlows([List E> messageFlows],StateStore stateStore,StateKeyClient stateKeyClient,StreamCompletionTracker completionTracker,EmittedStatsStore statsStore) --> InputBeanFactory.messageFlows([ConnectorInputStreams inputStreams],DataChannelFormat dataChannelFormat,ProtocolMessageDeserializer deserializer,DestinationMessageFactory destinationMessageFactory)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.resolveByBeanFactory(DefaultBeanContext.java:2341)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.doCreateBean(DefaultBeanContext.java:2296)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.doCreateBean(DefaultBeanContext.java:2308)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.createRegistration(DefaultBeanContext.java:3118)
2026-07-13 12:40:47 error at io.micronaut.context.SingletonScope.getOrCreate(SingletonScope.java:80)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.findOrCreateSingletonBeanRegistration(DefaultBeanContext.java:3020)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.resolveBeanRegistration(DefaultBeanContext.java:2981)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.resolveBeanRegistration(DefaultBeanContext.java:2747)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.getBean(DefaultBeanContext.java:1745)
2026-07-13 12:40:47 error at io.micronaut.context.AbstractBeanResolutionContext.getBean(AbstractBeanResolutionContext.java:89)
2026-07-13 12:40:47 error at io.micronaut.context.AbstractInitializableBeanDefinition.resolveBean(AbstractInitializableBeanDefinition.java:2188)
2026-07-13 12:40:47 error at io.micronaut.context.AbstractInitializableBeanDefinition.getBeanForConstructorArgument(AbstractInitializableBeanDefinition.java:1350)
2026-07-13 12:40:47 error at io.airbyte.cdk.load.dataflow.config.$InputBeanFactory$MessageFlows3$Definition.instantiate(Unknown Source)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.resolveByBeanFactory(DefaultBeanContext.java:2326)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.doCreateBean(DefaultBeanContext.java:2296)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.doCreateBean(DefaultBeanContext.java:2308)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.createRegistration(DefaultBeanContext.java:3118)
2026-07-13 12:40:47 error at io.micronaut.context.SingletonScope.getOrCreate(SingletonScope.java:80)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.findOrCreateSingletonBeanRegistration(DefaultBeanContext.java:3020)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.resolveBeanRegistration(DefaultBeanContext.java:2981)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.resolveBeanRegistration(DefaultBeanContext.java:2954)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.addCandidateToList(DefaultBeanContext.java:3572)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.resolveBeanRegistrations(DefaultBeanContext.java:3527)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.getBeanRegistrations(DefaultBeanContext.java:3501)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.getBeansOfType(DefaultBeanContext.java:1446)
2026-07-13 12:40:47 error at io.micronaut.context.AbstractBeanResolutionContext.getBeansOfType(AbstractBeanResolutionContext.java:95)
2026-07-13 12:40:47 error at io.micronaut.context.AbstractInitializableBeanDefinition.resolveBeansOfType(AbstractInitializableBeanDefinition.java:2276)
2026-07-13 12:40:47 error at io.micronaut.context.AbstractInitializableBeanDefinition.getBeansOfTypeForConstructorArgument(AbstractInitializableBeanDefinition.java:1498)
2026-07-13 12:40:47 error at io.airbyte.cdk.load.dataflow.config.$InputBeanFactory$InputFlows4$Definition.instantiate(Unknown Source)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.resolveByBeanFactory(DefaultBeanContext.java:2326)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.doCreateBean(DefaultBeanContext.java:2296)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.doCreateBean(DefaultBeanContext.java:2308)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.createRegistration(DefaultBeanContext.java:3118)
2026-07-13 12:40:47 error at io.micronaut.context.SingletonScope.getOrCreate(SingletonScope.java:80)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.findOrCreateSingletonBeanRegistration(DefaultBeanContext.java:3020)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.resolveBeanRegistration(DefaultBeanContext.java:2981)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.resolveBeanRegistration(DefaultBeanContext.java:2954)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.addCandidateToList(DefaultBeanContext.java:3572)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.resolveBeanRegistrations(DefaultBeanContext.java:3527)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.getBeanRegistrations(DefaultBeanContext.java:3501)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.getBeansOfType(DefaultBeanContext.java:1446)
2026-07-13 12:40:47 error at io.micronaut.context.AbstractBeanResolutionContext.getBeansOfType(AbstractBeanResolutionContext.java:95)
2026-07-13 12:40:47 error at io.micronaut.context.AbstractInitializableBeanDefinition.resolveBeansOfType(AbstractInitializableBeanDefinition.java:2276)
2026-07-13 12:40:47 error at io.micronaut.context.AbstractInitializableBeanDefinition.getBeansOfTypeForConstructorArgument(AbstractInitializableBeanDefinition.java:1498)
2026-07-13 12:40:47 error at io.airbyte.cdk.load.dataflow.config.$InputBeanFactory$Pipes6$Definition.instantiate(Unknown Source)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.resolveByBeanFactory(DefaultBeanContext.java:2326)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.doCreateBean(DefaultBeanContext.java:2296)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.doCreateBean(DefaultBeanContext.java:2308)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.createRegistration(DefaultBeanContext.java:3118)
2026-07-13 12:40:47 error at io.micronaut.context.SingletonScope.getOrCreate(SingletonScope.java:80)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.findOrCreateSingletonBeanRegistration(DefaultBeanContext.java:3020)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.resolveBeanRegistration(DefaultBeanContext.java:2981)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.resolveBeanRegistration(DefaultBeanContext.java:2954)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.addCandidateToList(DefaultBeanContext.java:3572)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.resolveBeanRegistrations(DefaultBeanContext.java:3527)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.getBeanRegistrations(DefaultBeanContext.java:3501)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.getBeansOfType(DefaultBeanContext.java:1446)
2026-07-13 12:40:47 error at io.micronaut.context.AbstractBeanResolutionContext.getBeansOfType(AbstractBeanResolutionContext.java:95)
2026-07-13 12:40:47 error at io.micronaut.context.AbstractInitializableBeanDefinition.resolveBeansOfType(AbstractInitializableBeanDefinition.java:2276)
2026-07-13 12:40:47 error at io.micronaut.context.AbstractInitializableBeanDefinition.getBeansOfTypeForConstructorArgument(AbstractInitializableBeanDefinition.java:1498)
2026-07-13 12:40:47 error at io.airbyte.cdk.load.dataflow.pipeline.$PipelineRunner$Definition.instantiate(Unknown Source)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.resolveByBeanFactory(DefaultBeanContext.java:2326)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.doCreateBean(DefaultBeanContext.java:2296)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.doCreateBean(DefaultBeanContext.java:2308)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.createRegistration(DefaultBeanContext.java:3118)
2026-07-13 12:40:47 error at io.micronaut.context.SingletonScope.getOrCreate(SingletonScope.java:80)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.findOrCreateSingletonBeanRegistration(DefaultBeanContext.java:3020)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.resolveBeanRegistration(DefaultBeanContext.java:2981)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.resolveBeanRegistration(DefaultBeanContext.java:2747)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.getBean(DefaultBeanContext.java:1745)
2026-07-13 12:40:47 error at io.micronaut.context.AbstractBeanResolutionContext.getBean(AbstractBeanResolutionContext.java:89)
2026-07-13 12:40:47 error at io.micronaut.context.AbstractInitializableBeanDefinition.resolveBean(AbstractInitializableBeanDefinition.java:2188)
2026-07-13 12:40:47 error at io.micronaut.context.AbstractInitializableBeanDefinition.getBeanForConstructorArgument(AbstractInitializableBeanDefinition.java:1350)
2026-07-13 12:40:47 error at io.airbyte.cdk.load.dataflow.$DestinationLifecycle$Definition.instantiate(Unknown Source)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.resolveByBeanFactory(DefaultBeanContext.java:2326)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.doCreateBean(DefaultBeanContext.java:2296)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.doCreateBean(DefaultBeanContext.java:2308)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.createRegistration(DefaultBeanContext.java:3118)
2026-07-13 12:40:47 error at io.micronaut.context.SingletonScope.getOrCreate(SingletonScope.java:80)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.findOrCreateSingletonBeanRegistration(DefaultBeanContext.java:3020)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.resolveBeanRegistration(DefaultBeanContext.java:2981)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.resolveBeanRegistration(DefaultBeanContext.java:2747)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.getBean(DefaultBeanContext.java:1745)
2026-07-13 12:40:47 error at io.micronaut.context.AbstractBeanResolutionContext.getBean(AbstractBeanResolutionContext.java:89)
2026-07-13 12:40:47 error at io.micronaut.context.AbstractInitializableBeanDefinition.resolveBean(AbstractInitializableBeanDefinition.java:2188)
2026-07-13 12:40:47 error at io.micronaut.context.AbstractInitializableBeanDefinition.getBeanForConstructorArgument(AbstractInitializableBeanDefinition.java:1350)
2026-07-13 12:40:47 error at io.airbyte.cdk.load.write.$WriteOperation$Definition.instantiate(Unknown Source)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.resolveByBeanFactory(DefaultBeanContext.java:2326)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.doCreateBean(DefaultBeanContext.java:2296)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.doCreateBean(DefaultBeanContext.java:2308)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.createRegistration(DefaultBeanContext.java:3118)
2026-07-13 12:40:47 error at io.micronaut.context.SingletonScope.getOrCreate(SingletonScope.java:80)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.findOrCreateSingletonBeanRegistration(DefaultBeanContext.java:3020)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.resolveBeanRegistration(DefaultBeanContext.java:2981)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.resolveBeanRegistration(DefaultBeanContext.java:2747)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.getBean(DefaultBeanContext.java:1745)
2026-07-13 12:40:47 error at io.micronaut.inject.provider.JakartaProviderBeanDefinition.lambda$buildProvider$0(JakartaProviderBeanDefinition.java:65)
2026-07-13 12:40:47 error at io.airbyte.cdk.AirbyteConnectorRunnable.run(AirbyteConnectorRunnable.kt:31)
2026-07-13 12:40:47 error ... 11 more
2026-07-13 12:40:47 error Caused by: java.net.ConnectException: Connection refused
2026-07-13 12:40:47 error at java.base/sun.nio.ch.UnixDomainSockets.connect0(Native Method)
2026-07-13 12:40:47 error at java.base/sun.nio.ch.UnixDomainSockets.connect(UnixDomainSockets.java:154)
2026-07-13 12:40:47 error at java.base/sun.nio.ch.UnixDomainSockets.connect(UnixDomainSockets.java:150)
2026-07-13 12:40:47 error at java.base/sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:878)
2026-07-13 12:40:47 error at io.airbyte.cdk.load.file.ClientSocket.openInputStream(ClientSocket.kt:45)
2026-07-13 12:40:47 error at io.airbyte.cdk.load.dataflow.config.InputBeanFactory.socketStreams(InputBeanFactory.kt:86)
2026-07-13 12:40:47 error at io.airbyte.cdk.load.dataflow.config.$InputBeanFactory$SocketStreams1$Definition.instantiate(Unknown Source)
2026-07-13 12:40:47 error at io.micronaut.context.DefaultBeanContext.resolveByBeanFactory(DefaultBeanContext.java:2326)
2026-07-13 12:40:47 error ... 108 more
2026-07-13 12:40:47 info INFO main i.a.c.d.JdbcMetadataQuerier$memoizedTableNames$2(invoke):114 Querying table names for catalog discovery.
2026-07-13 12:40:48 info INFO main i.a.c.d.JdbcMetadataQuerier$memoizedTableNames$2(invoke):160 Discovered 332 table(s) in namespaces [xxx].
2026-07-13 12:40:48 info INFO main i.a.c.d.JdbcMetadataQuerier$memoizedColumnMetadata$2(invoke):174 Querying column names for catalog discovery.
2026-07-13 12:40:49 info INFO main i.a.c.d.JdbcMetadataQuerier$memoizedColumnMetadata$2(invoke):223 Discovered 2788 column(s) and pseudo-column(s).
2026-07-13 12:40:49 info INFO main i.a.c.d.JdbcMetadataQuerier(close):434 Closing JDBC connection.
2026-07-13 12:40:49 info INFO DefaultDispatcher-worker-6#read i.a.c.r.RootReader(read):91 Read configured with data channel medium: SOCKET. data channel format: PROTOBUF
2026-07-13 12:40:49 info INFO DefaultDispatcher-worker-6#read i.a.c.r.RootReader(read):178 Reading feeds of type class io.airbyte.cdk.read.Global.
2026-07-13 12:40:49 info INFO DefaultDispatcher-worker-6#read i.a.c.r.ReadOperation$execute$1$1$1(invokeSuspend):80 coroutine state:
read
└─global
└─global-round-1-partition-creator-factory-acquire-resources-io.airbyte.cdk.read.cdc.CdcPartitionsCreatorFactory@71554bc8

2026-07-13 12:40:49 info INFO DefaultDispatcher-worker-5#global-round-1-partition-creator-factory-acquire-resources-io.airbyte.cdk.read.cdc.CdcPartitionsCreatorFactory@71554bc8 i.a.c.r.FeedReader(acquirePartitionsCreatorFactoryResources):145 acquired resources to make partitions creator factory 'CdcPartitionsCreatorFactory' for 'global' in round 1
2026-07-13 12:40:49 info INFO DefaultDispatcher-worker-6#global i.a.c.r.FeedReader(createPartitions):114 Attempting bootstrap using class io.airbyte.cdk.read.cdc.CdcPartitionsCreatorFactory.
2026-07-13 12:40:49 info INFO DefaultDispatcher-worker-6#global-round-1-make-partitions-creator i.a.c.r.FeedReader(makePartitionsCreatorWithResources):179 releasing resources acquired to make partitions creator factory for 'global'
2026-07-13 12:40:49 info INFO DefaultDispatcher-worker-7#global-round-1-acquire-resources i.a.c.r.FeedReader(acquirePartitionsCreatorResources):166 acquired resources to create partitions for 'global' in round 1
2026-07-13 12:40:49 info INFO DefaultDispatcher-worker-7#read i.a.c.r.ReadOperation$execute$1$1$1(invokeSuspend):80 coroutine state:
read
└─global
```

---
**Internal Tracking:** https://github.com/airbytehq/oncall/issues/13099