[source-clickhouse] SQLFeatureNotSupportedException: getResultSet not implemented #61419
Description
Connector Name
source-clickhouse
Connector Version
0.2.3
What step the error happened?
During the sync
Relevant information
The Clickhouse DB source has been setup successfully. I've also tested the connection to it and it also worked well. However, whenever I have been trying to sync data between data for 4 tables in Clickhouse (the data is not large) to the blob storage in Azure, I always encounter the error related to "getResultSet()". The errors look like as follows:
"java.lang.RuntimeException: java.sql.SQLFeatureNotSupportedException: getResultSet not implemented"
{ "failureOrigin" : "destination", "failureType" : "transient_error", "internalMessage" : "io.airbyte.cdk.TransientErrorException: Input was fully read, but some streams did not receive a terminal stream status message. This likely indicates an error in the source or platform. Streams without a status message: [null.users_test, null.questions, null.options, null.users, null.browsinghistory]", "externalMessage" : "Input was fully read, but some streams did not receive a terminal stream status message. This likely indicates an error in the source or platform. Streams without a status message: [null.users_test, null.questions, null.options, null.users, null.browsinghistory]", "metadata" : { "attemptNumber" : 0, "jobId" : 3, "from_trace_message" : true, "connector_command" : "write" }, "stacktrace" : "io.airbyte.cdk.TransientErrorException: Input was fully read, but some streams did not receive a terminal stream status message. This likely indicates an error in the source or platform. Streams without a status message: [null.users_test, null.questions, null.options, null.users, null.browsinghistory]\n\tat io.airbyte.cdk.load.state.SyncManager.markInputConsumed(SyncManager.kt:118)\n\tat io.airbyte.cdk.load.task.internal.DefaultInputConsumerTask.execute(InputConsumerTask.kt:298)\n\tat io.airbyte.cdk.load.task.DestinationTaskLauncher$WrappedTask.execute(DestinationTaskLauncher.kt:163)\n\tat io.airbyte.cdk.load.task.TaskScopeProvider$launch$job$1.invokeSuspend(TaskScopeProvider.kt:35)\n\tat kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33)\n\tat kotlinx.coroutines.DispatchedTask.run(DispatchedTask.kt:104)\n\tat kotlinx.coroutines.internal.LimitedDispatcher$Worker.run(LimitedDispatcher.kt:111)\n\tat kotlinx.coroutines.scheduling.TaskImpl.run(Tasks.kt:99)\n\tat kotlinx.coroutines.scheduling.CoroutineScheduler.runSafely(CoroutineScheduler.kt:584)\n\tat kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.executeTask(CoroutineScheduler.kt:811)\n\tat kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.runWorker(CoroutineScheduler.kt:715)\n\tat kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.run(CoroutineScheduler.kt:702)\n", "timestamp" : 1749220810409 }
Relevant log output
2025-06-06 23:40:11 replication-orchestrator INFO failures: [ {
"failureOrigin" : "source",
"failureType" : "system_error",
"internalMessage" : "java.lang.RuntimeException: java.sql.SQLFeatureNotSupportedException: getResultSet not implemented",
"externalMessage" : "Something went wrong in the connector. See the logs for more details.",
"metadata" : {
"attemptNumber" : 0,
"jobId" : 3,
"from_trace_message" : true,
"connector_command" : "read"
},
"stacktrace" : "java.lang.RuntimeException: java.sql.SQLFeatureNotSupportedException: getResultSet not implemented\n\tat io.airbyte.cdk.db.jdbc.StreamingJdbcDatabase$1.tryAdvance(StreamingJdbcDatabase.java:112)\n\tat java.base/java.util.Spliterators$1Adapter.hasNext(Spliterators.java:681)\n\tat io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42)\n\tat com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)\n\tat com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)\n\tat io.airbyte.commons.util.LazyAutoCloseableIterator.computeNext(LazyAutoCloseableIterator.java:46)\n\tat com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)\n\tat com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)\n\tat com.google.common.collect.TransformedIterator.hasNext(TransformedIterator.java:46)\n\tat io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42)\n\tat com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)\n\tat com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)\n\tat io.airbyte.cdk.integrations.source.relationaldb.StateDecoratingIterator.computeNext(StateDecoratingIterator.java:127)\n\tat io.airbyte.cdk.integrations.source.relationaldb.StateDecoratingIterator.computeNext(StateDecoratingIterator.java:22)\n\tat com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)\n\tat com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)\n\tat io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42)\n\tat com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)\n\tat com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)\n\tat com.google.common.collect.TransformedIterator.hasNext(TransformedIterator.java:46)\n\tat io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42)\n\tat com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)\n\tat com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)\n\tat io.airbyte.commons.util.CompositeIterator.computeNext(CompositeIterator.java:74)\n\tat com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)\n\tat com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)\n\tat io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42)\n\tat com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)\n\tat com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)\n\tat io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42)\n\tat com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)\n\tat com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)\n\tat java.base/java.util.Iterator.forEachRemaining(Iterator.java:132)\n\tat io.airbyte.cdk.integrations.base.IntegrationRunner.produceMessages(IntegrationRunner.java:236)\n\tat io.airbyte.cdk.integrations.base.IntegrationRunner.readSerial(IntegrationRunner.java:276)\n\tat io.airbyte.cdk.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:173)\n\tat io.airbyte.cdk.integrations.base.IntegrationRunner.run(IntegrationRunner.java:125)\n\tat io.airbyte.integrations.source.clickhouse.ClickHouseSource.main(ClickHouseSource.java:134)\n\tSuppressed: java.lang.RuntimeException: java.sql.SQLFeatureNotSupportedException: getResultSet not implemented\n\t\tat io.airbyte.cdk.db.jdbc.StreamingJdbcDatabase.lambda$unsafeQuery$0(StreamingJdbcDatabase.java:77)\n\t\tat java.base/java.util.stream.AbstractPipeline.close(AbstractPipeline.java:323)\n\t\tat io.airbyte.commons.concurrency.VoidCallable.call(VoidCallable.java:15)\n\t\tat io.airbyte.commons.util.DefaultAutoCloseableIterator.close(DefaultAutoCloseableIterator.java:53)\n\t\tat io.airbyte.commons.util.LazyAutoCloseableIterator.close(LazyAutoCloseableIterator.java:56)\n\t\tat io.airbyte.commons.concurrency.VoidCallable.call(VoidCallable.java:15)\n\t\tat io.airbyte.commons.util.DefaultAutoCloseableIterator.close(DefaultAutoCloseableIterator.java:53)\n\t\tat io.airbyte.commons.concurrency.VoidCallable.call(VoidCallable.java:15)\n\t\tat io.airbyte.commons.util.DefaultAutoCloseableIterator.close(DefaultAutoCloseableIterator.java:53)\n\t\tat io.airbyte.commons.concurrency.VoidCallable.call(VoidCallable.java:15)\n\t\tat io.airbyte.commons.util.DefaultAutoCloseableIterator.close(DefaultAutoCloseableIterator.java:53)\n\t\tat io.airbyte.commons.util.CompositeIterator.close(CompositeIterator.java:124)\n\t\tat io.airbyte.commons.util.AutoCloseableIterators.lambda$appendOnClose$0(AutoCloseableIterators.java:106)\n\t\tat io.airbyte.commons.concurrency.VoidCallable.call(VoidCallable.java:15)\n\t\tat io.airbyte.commons.util.DefaultAutoCloseableIterator.close(DefaultAutoCloseableIterator.java:53)\n\t\tat io.airbyte.commons.util.AutoCloseableIterators.lambda$appendOnClose$0(AutoCloseableIterators.java:106)\n\t\tat io.airbyte.commons.concurrency.VoidCallable.call(VoidCallable.java:15)\n\t\tat io.airbyte.commons.util.DefaultAutoCloseableIterator.close(DefaultAutoCloseableIterator.java:53)\n\t\tat io.airbyte.cdk.integrations.base.IntegrationRunner.readSerial(IntegrationRunner.java:275)\n\t\t... 3 more\n\tCaused by: java.sql.SQLFeatureNotSupportedException: getResultSet not implemented\n\t\tat com.clickhouse.jdbc.SqlExceptionUtils.unsupportedError(SqlExceptionUtils.java:138)\n\t\tat com.clickhouse.jdbc.ClickHouseArray.getResultSet(ClickHouseArray.java:74)\n\t\tat io.airbyte.cdk.db.jdbc.AbstractJdbcCompatibleSourceOperations.putArray(AbstractJdbcCompatibleSourceOperations.java:68)\n\t\tat io.airbyte.cdk.db.jdbc.JdbcSourceOperations.copyToJsonField(JdbcSourceOperations.java:63)\n\t\tat io.airbyte.cdk.db.jdbc.AbstractJdbcCompatibleSourceOperations.rowToJson(AbstractJdbcCompatibleSourceOperations.java:60)\n\t\tat io.airbyte.cdk.db.jdbc.AbstractJdbcCompatibleSourceOperations.rowToJson(AbstractJdbcCompatibleSourceOperations.java:37)\n\t\tat io.airbyte.cdk.db.jdbc.StreamingJdbcDatabase$1.tryAdvance(StreamingJdbcDatabase.java:104)\n\t\tat java.base/java.util.Spliterators$1Adapter.hasNext(Spliterators.java:681)\n\t\tat io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42)\n\t\tat com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)\n\t\tat com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)\n\t\tat io.airbyte.commons.util.LazyAutoCloseableIterator.computeNext(LazyAutoCloseableIterator.java:46)\n\t\tat com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)\n\t\tat com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)\n\t\tat com.google.common.collect.TransformedIterator.hasNext(TransformedIterator.java:46)\n\t\tat io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42)\n\t\tat com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)\n\t\tat com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)\n\t\tat io.airbyte.cdk.integrations.source.relationaldb.StateDecoratingIterator.computeNext(StateDecoratingIterator.java:127)\n\t\tat io.airbyte.cdk.integrations.source.relationaldb.StateDecoratingIterator.computeNext(StateDecoratingIterator.java:22)\n\t\tat com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)\n\t\tat com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)\n\t\tat io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42)\n\t\tat com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)\n\t\tat com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)\n\t\tat com.google.common.collect.TransformedIterator.hasNext(TransformedIterator.java:46)\n\t\tat io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42)\n\t\tat com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)\n\t\tat com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)\n\t\tat io.airbyte.commons.util.CompositeIterator.computeNext(CompositeIterator.java:74)\n\t\tat com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)\n\t\tat com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)\n\t\tat io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42)\n\t\tat com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)\n\t\tat com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)\n\t\tat io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42)\n\t\tat com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)\n\t\tat com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)\n\t\tat java.base/java.util.Iterator.forEachRemaining(Iterator.java:132)\n\t\tat io.airbyte.cdk.integrations.base.IntegrationRunner.produceMessages(IntegrationRunner.java:236)\n\t\tat io.airbyte.cdk.integrations.base.IntegrationRunner.readSerial(IntegrationRunner.java:276)\n\t\t... 3 more\nCaused by: [CIRCULAR REFERENCE: java.sql.SQLFeatureNotSupportedException: getResultSet not implemented]\n",
"timestamp" : 1749220804522
}, {
"failureOrigin" : "destination",
"failureType" : "transient_error",
"internalMessage" : "io.airbyte.cdk.TransientErrorException: Input was fully read, but some streams did not receive a terminal stream status message. This likely indicates an error in the source or platform. Streams without a status message: [null.users_test, null.questions, null.options, null.users, null.browsinghistory]",
"externalMessage" : "Input was fully read, but some streams did not receive a terminal stream status message. This likely indicates an error in the source or platform. Streams without a status message: [null.users_test, null.questions, null.options, null.users, null.browsinghistory]",
"metadata" : {
"attemptNumber" : 0,
"jobId" : 3,
"from_trace_message" : true,
"connector_command" : "write"
},
"stacktrace" : "io.airbyte.cdk.TransientErrorException: Input was fully read, but some streams did not receive a terminal stream status message. This likely indicates an error in the source or platform. Streams without a status message: [null.users_test, null.questions, null.options, null.users, null.browsinghistory]\n\tat io.airbyte.cdk.load.state.SyncManager.markInputConsumed(SyncManager.kt:118)\n\tat io.airbyte.cdk.load.task.internal.DefaultInputConsumerTask.execute(InputConsumerTask.kt:298)\n\tat io.airbyte.cdk.load.task.DestinationTaskLauncher$WrappedTask.execute(DestinationTaskLauncher.kt:163)\n\tat io.airbyte.cdk.load.task.TaskScopeProvider$launch$job$1.invokeSuspend(TaskScopeProvider.kt:35)\n\tat kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33)\n\tat kotlinx.coroutines.DispatchedTask.run(DispatchedTask.kt:104)\n\tat kotlinx.coroutines.internal.LimitedDispatcher$Worker.run(LimitedDispatcher.kt:111)\n\tat kotlinx.coroutines.scheduling.TaskImpl.run(Tasks.kt:99)\n\tat kotlinx.coroutines.scheduling.CoroutineScheduler.runSafely(CoroutineScheduler.kt:584)\n\tat kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.executeTask(CoroutineScheduler.kt:811)\n\tat kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.runWorker(CoroutineScheduler.kt:715)\n\tat kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.run(CoroutineScheduler.kt:702)\n",
"timestamp" : 1749220810409
}, {
"failureOrigin" : "source",
"internalMessage" : "Source process exited with non-zero exit code 1",
"externalMessage" : "Something went wrong within the source connector",
"metadata" : {
"attemptNumber" : 0,
"jobId" : 3,
"connector_command" : "read"
},
"stacktrace" : "io.airbyte.workers.internal.exception.SourceException: Source process exited with non-zero exit code 1\n\tat io.airbyte.workers.general.BufferedReplicationWorker.readFromSource(BufferedReplicationWorker.java:365)\n\tat io.airbyte.workers.general.BufferedReplicationWorker.lambda$runAsyncWithHeartbeatCheck$3(BufferedReplicationWorker.java:223)\n\tat java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)\n\tat java.base/java.lang.Thread.run(Thread.java:1583)\n",
"timestamp" : 1749220804746
}, {
"failureOrigin" : "destination",
"internalMessage" : "Destination process exited with non-zero exit code 1",
"externalMessage" : "Something went wrong within the destination connector",
"metadata" : {
"attemptNumber" : 0,
"jobId" : 3,
"connector_command" : "write"
},
"stacktrace" : "io.airbyte.workers.internal.exception.DestinationException: Destination process exited with non-zero exit code 1\n\tat io.airbyte.workers.general.BufferedReplicationWorker.readFromDestination(BufferedReplicationWorker.java:503)\n\tat io.airbyte.workers.general.BufferedReplicationWorker.lambda$runAsync$2(BufferedReplicationWorker.java:216)\n\tat java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)\n\tat java.base/java.lang.Thread.run(Thread.java:1583)\n",
"timestamp" : 1749220810859
}, {
"failureOrigin" : "replication",
"internalMessage" : "io.airbyte.workers.exception.WorkerException: Destination process exit with code 1. This warning is normal if the job was cancelled.",
"externalMessage" : "Something went wrong during replication",
"metadata" : {
"attemptNumber" : 0,
"jobId" : 3
},
"stacktrace" : "java.lang.RuntimeException: io.airbyte.workers.exception.WorkerException: Destination process exit with code 1. This warning is normal if the job was cancelled.\n\tat io.airbyte.workers.general.BufferedReplicationWorker$CloseableWithTimeout.lambda$close$0(BufferedReplicationWorker.java:548)\n\tat io.airbyte.workers.general.BufferedReplicationWorker.lambda$runAsyncWithTimeout$5(BufferedReplicationWorker.java:244)\n\tat java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)\n\tat java.base/java.lang.Thread.run(Thread.java:1583)\nCaused by: io.airbyte.workers.exception.WorkerException: Destination process exit with code 1. This warning is normal if the job was cancelled.\n\tat io.airbyte.workers.internal.LocalContainerAirbyteDestination.close(LocalContainerAirbyteDestination.kt:61)\n\tat io.airbyte.workers.general.BufferedReplicationWorker$CloseableWithTimeout.lambda$close$0(BufferedReplicationWorker.java:546)\n\t... 5 more\n",
"timestamp" : 1749220810905
} ]
2025-06-06 23:40:11 replication-orchestrator INFO
2025-06-06 23:40:11 replication-orchestrator INFO ----- END REPLICATION -----
2025-06-06 23:40:11 replication-orchestrator INFO
2025-06-06 23:40:12 replication-orchestrator INFO Returning output...
2025-06-06 23:40:12 platform INFO Closing Segment analytics client...
2025-06-06 23:40:12 platform INFO Waiting for Segment analytic client to flush enqueued messages...
2025-06-06 23:40:12 platform INFO Segment analytic client flush complete.
2025-06-06 23:40:12 platform INFO Segment analytics client closed. No new events will be accepted.
2025-06-06 23:40:12 platform INFO
----- START POST REPLICATION OPERATIONS -----
2025-06-06 23:40:12 platform INFO No post-replication operation(s) to perform.
2025-06-06 23:40:12 platform INFO
----- END POST REPLICATION OPERATIONS -----Contribute
- Yes, I want to contribute