Clickhouse-source aborting connection with `java.io.IOException: Premature EOF` even with `socket_timeout` param passed through JDBC URL connection string

### Connector Name

source-clickhouse

### Connector Version

0.2.6

### What step the error happened?

During the sync

### Relevant information

Hi! I'm having issues with a connection being disconnected due to SOCKET_TIMEOUT from an airbyte connection that has ClickhouseDB as a source and Postgres as a destination.

I've searched around and found the following references

* https://github.com/ClickHouse/clickhouse-rs/issues/175 (configuring server)
* github.com/ClickHouse/clickhouse-java/issues/1822 (configuring client)

# Steps to reproduce (sort of)

- have an `airbyte` user on clickhouse
- pass `socket_timeout=300000` to the jdbc url on the configuration UI on airbyte
- have a sync incremental job set up that takes more than 30 seconds
- ensure settings are being logged on Clickhouse

SELECT
name,
value
FROM system.settings
WHERE name = 'log_query_settings'

Query id: 4ee634bc-178b-4f82-8fe3-108e266bf93a

┌─name───────────────┬─value─┐
1. │ log_query_settings │ 1 │
└────────────────────┴───────┘
- check on clickhouse that the queries issued by airbyte the passed in Settings don't reference `socket_timeout`

SELECT Settings
FROM system.query_log
WHERE user = 'airbyte'
ORDER BY event_time DESC
LIMIT 1
FORMAT vertical

Query id: eda59be9-b249-4bb0-8b96-0c4397c6e45c

Row 1:
──────
Settings: {'http_receive_timeout':'150','parallel_replicas_for_cluster_engines':'0'}

- have the sync job fail with a timeout error `java.sql.SQLException: java.io.IOException: Premature EOF` (See full error below)

# Versions

* source connector ClickHouse v0.2.6
* destination Postgres v2.2.1
* airbyte version 0.50.31

# Other references

- Thread in `Airbyte` slack channel https://airbytehq.slack.com/archives/C021JANJ6TY/p1763120078172969
- Thread in `Clickhouse` slack channel https://clickhousedb.slack.com/archives/CU478UEQZ/p1763133612116389

### Relevant log output

```shell
2025-11-14 14:01:55 source > ERROR i.a.c.u.CompositeIterator(close):126 exception while closing java.lang.RuntimeException: java.sql.SQLException: java.io.IOException: Premature EOF
at io.airbyte.cdk.db.jdbc.StreamingJdbcDatabase.lambda$unsafeQuery$0(StreamingJdbcDatabase.java:77) ~[airbyte-cdk-core-0.20.4.jar:?]
at java.base/java.util.stream.AbstractPipeline.close(AbstractPipeline.java:323) ~[?:?]
at io.airbyte.commons.concurrency.VoidCallable.call(VoidCallable.java:15) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at io.airbyte.commons.util.DefaultAutoCloseableIterator.close(DefaultAutoCloseableIterator.java:53) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at io.airbyte.commons.util.LazyAutoCloseableIterator.close(LazyAutoCloseableIterator.java:56) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at io.airbyte.commons.concurrency.VoidCallable.call(VoidCallable.java:15) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at io.airbyte.commons.util.DefaultAutoCloseableIterator.close(DefaultAutoCloseableIterator.java:53) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at io.airbyte.commons.concurrency.VoidCallable.call(VoidCallable.java:15) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at io.airbyte.commons.util.DefaultAutoCloseableIterator.close(DefaultAutoCloseableIterator.java:53) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at io.airbyte.commons.concurrency.VoidCallable.call(VoidCallable.java:15) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at io.airbyte.commons.util.DefaultAutoCloseableIterator.close(DefaultAutoCloseableIterator.java:53) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at io.airbyte.commons.util.CompositeIterator.close(CompositeIterator.java:124) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at io.airbyte.commons.util.AutoCloseableIterators.lambda$appendOnClose$0(AutoCloseableIterators.java:106) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at io.airbyte.commons.concurrency.VoidCallable.call(VoidCallable.java:15) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at io.airbyte.commons.util.DefaultAutoCloseableIterator.close(DefaultAutoCloseableIterator.java:53) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at io.airbyte.commons.util.AutoCloseableIterators.lambda$appendOnClose$0(AutoCloseableIterators.java:106) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at io.airbyte.commons.concurrency.VoidCallable.call(VoidCallable.java:15) [airbyte-cdk-dependencies-0.20.4.jar:?]
at io.airbyte.commons.util.DefaultAutoCloseableIterator.close(DefaultAutoCloseableIterator.java:53) [airbyte-cdk-dependencies-0.20.4.jar:?]
at io.airbyte.cdk.integrations.base.IntegrationRunner.readSerial(IntegrationRunner.java:275) [airbyte-cdk-core-0.20.4.jar:?]
at io.airbyte.cdk.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:173) [airbyte-cdk-core-0.20.4.jar:?]
at io.airbyte.cdk.integrations.base.IntegrationRunner.run(IntegrationRunner.java:125) [airbyte-cdk-core-0.20.4.jar:?]
at io.airbyte.integrations.source.clickhouse.ClickHouseSource.main(ClickHouseSource.java:134) [io.airbyte.airbyte-integrations.connectors-source-clickhouse.jar:?]
Caused by: java.sql.SQLException: java.io.IOException: Premature EOF
at com.clickhouse.jdbc.SqlExceptionUtils.handle(SqlExceptionUtils.java:77) ~[clickhouse-jdbc-0.3.2-patch10-all.jar:clickhouse-jdbc 0.3.2-patch10 (revision: aebad16)]
at com.clickhouse.jdbc.ClickHouseResultSet.next(ClickHouseResultSet.java:716) ~[clickhouse-jdbc-0.3.2-patch10-all.jar:clickhouse-jdbc 0.3.2-patch10 (revision: aebad16)]
at com.zaxxer.hikari.pool.HikariProxyResultSet.next(HikariProxyResultSet.java) ~[HikariCP-5.1.0.jar:?]
at io.airbyte.cdk.db.jdbc.StreamingJdbcDatabase$1.tryAdvance(StreamingJdbcDatabase.java:100) ~[airbyte-cdk-core-0.20.4.jar:?]
at java.base/java.util.Spliterators$1Adapter.hasNext(Spliterators.java:681) ~[?:?]
at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145) ~[guava-33.0.0-jre.jar:?]
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140) ~[guava-33.0.0-jre.jar:?]
at io.airbyte.commons.util.LazyAutoCloseableIterator.computeNext(LazyAutoCloseableIterator.java:46) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145) ~[guava-33.0.0-jre.jar:?]
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140) ~[guava-33.0.0-jre.jar:?]
at com.google.common.collect.TransformedIterator.hasNext(TransformedIterator.java:46) ~[guava-33.0.0-jre.jar:?]
at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145) ~[guava-33.0.0-jre.jar:?]
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140) ~[guava-33.0.0-jre.jar:?]
at io.airbyte.cdk.integrations.source.relationaldb.StateDecoratingIterator.computeNext(StateDecoratingIterator.java:127) ~[airbyte-cdk-db-sources-0.20.4.jar:?]
at io.airbyte.cdk.integrations.source.relationaldb.StateDecoratingIterator.computeNext(StateDecoratingIterator.java:22) ~[airbyte-cdk-db-sources-0.20.4.jar:?]
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145) ~[guava-33.0.0-jre.jar:?]
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140) ~[guava-33.0.0-jre.jar:?]
at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145) ~[guava-33.0.0-jre.jar:?]
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140) ~[guava-33.0.0-jre.jar:?]
at com.google.common.collect.TransformedIterator.hasNext(TransformedIterator.java:46) ~[guava-33.0.0-jre.jar:?]
at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145) ~[guava-33.0.0-jre.jar:?]
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140) ~[guava-33.0.0-jre.jar:?]
at io.airbyte.commons.util.CompositeIterator.computeNext(CompositeIterator.java:74) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145) ~[guava-33.0.0-jre.jar:?]
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140) ~[guava-33.0.0-jre.jar:?]
at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145) ~[guava-33.0.0-jre.jar:?]
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140) ~[guava-33.0.0-jre.jar:?]
at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145) ~[guava-33.0.0-jre.jar:?]
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140) ~[guava-33.0.0-jre.jar:?]
at java.base/java.util.Iterator.forEachRemaining(Iterator.java:132) ~[?:?]
at io.airbyte.cdk.integrations.base.IntegrationRunner.produceMessages(IntegrationRunner.java:236) ~[airbyte-cdk-core-0.20.4.jar:?]
at io.airbyte.cdk.integrations.base.IntegrationRunner.readSerial(IntegrationRunner.java:276) ~[airbyte-cdk-core-0.20.4.jar:?]
... 3 more
Caused by: java.io.IOException: Premature EOF
at java.base/sun.net.www.http.ChunkedInputStream.readAheadBlocking(ChunkedInputStream.java:567) ~[?:?]
at java.base/sun.net.www.http.ChunkedInputStream.readAhead(ChunkedInputStream.java:611) ~[?:?]
at java.base/sun.net.www.http.ChunkedInputStream.read(ChunkedInputStream.java:705) ~[?:?]
at java.base/java.io.FilterInputStream.read(FilterInputStream.java:119) ~[?:?]
at java.base/sun.net.www.protocol.http.HttpURLConnection$HttpInputStream.read(HttpURLConnection.java:3692) ~[?:?]
at com.clickhouse.client.stream.Lz4InputStream.readFully(Lz4InputStream.java:34) ~[clickhouse-jdbc-0.3.2-patch10-all.jar:clickhouse-jdbc 0.3.2-patch10 (revision: aebad16)]
at com.clickhouse.client.stream.Lz4InputStream.updateBuffer(Lz4InputStream.java:72) ~[clickhouse-jdbc-0.3.2-patch10-all.jar:clickhouse-jdbc 0.3.2-patch10 (revision: aebad16)]
at com.clickhouse.client.stream.AbstractByteArrayInputStream.ensureOpen(AbstractByteArrayInputStream.java:36) ~[clickhouse-jdbc-0.3.2-patch10-all.jar:clickhouse-jdbc 0.3.2-patch10 (revision: aebad16)]
at com.clickhouse.client.stream.AbstractByteArrayInputStream.readByte(AbstractByteArrayInputStream.java:214) ~[clickhouse-jdbc-0.3.2-patch10-all.jar:clickhouse-jdbc 0.3.2-patch10 (revision: aebad16)]
at com.clickhouse.client.data.ClickHouseRowBinaryProcessor$MappedFunctions.lambda$buildMappingsForDataTypes$10(ClickHouseRowBinaryProcessor.java:208) ~[clickhouse-jdbc-0.3.2-patch10-all.jar:clickhouse-jdbc 0.3.2-patch10 (revision: aebad16)]
at com.clickhouse.client.data.ClickHouseRowBinaryProcessor$MappedFunctions.deserialize(ClickHouseRowBinaryProcessor.java:466) ~[clickhouse-jdbc-0.3.2-patch10-all.jar:clickhouse-jdbc 0.3.2-patch10 (revision: aebad16)]
at com.clickhouse.client.data.ClickHouseRowBinaryProcessor.readAndFill(ClickHouseRowBinaryProcessor.java:509) ~[clickhouse-jdbc-0.3.2-patch10-all.jar:clickhouse-jdbc 0.3.2-patch10 (revision: aebad16)]
at com.clickhouse.client.ClickHouseDataProcessor.nextRecord(ClickHouseDataProcessor.java:143) ~[clickhouse-jdbc-0.3.2-patch10-all.jar:clickhouse-jdbc 0.3.2-patch10 (revision: aebad16)]
at com.clickhouse.client.ClickHouseDataProcessor.access$100(ClickHouseDataProcessor.java:21) ~[clickhouse-jdbc-0.3.2-patch10-all.jar:clickhouse-jdbc 0.3.2-patch10 (revision: aebad16)]
at com.clickhouse.client.ClickHouseDataProcessor$RecordsIterator.next(ClickHouseDataProcessor.java:36) ~[clickhouse-jdbc-0.3.2-patch10-all.jar:clickhouse-jdbc 0.3.2-patch10 (revision: aebad16)]
at com.clickhouse.client.ClickHouseDataProcessor$RecordsIterator.next(ClickHouseDataProcessor.java:22) ~[clickhouse-jdbc-0.3.2-patch10-all.jar:clickhouse-jdbc 0.3.2-patch10 (revision: aebad16)]
at com.clickhouse.jdbc.ClickHouseResultSet.next(ClickHouseResultSet.java:714) ~[clickhouse-jdbc-0.3.2-patch10-all.jar:clickhouse-jdbc 0.3.2-patch10 (revision: aebad16)]
at com.zaxxer.hikari.pool.HikariProxyResultSet.next(HikariProxyResultSet.java) ~[HikariCP-5.1.0.jar:?]
at io.airbyte.cdk.db.jdbc.StreamingJdbcDatabase$1.tryAdvance(StreamingJdbcDatabase.java:100) ~[airbyte-cdk-core-0.20.4.jar:?]
at java.base/java.util.Spliterators$1Adapter.hasNext(Spliterators.java:681) ~[?:?]
at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145) ~[guava-33.0.0-jre.jar:?]
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140) ~[guava-33.0.0-jre.jar:?]
at io.airbyte.commons.util.LazyAutoCloseableIterator.computeNext(LazyAutoCloseableIterator.java:46) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145) ~[guava-33.0.0-jre.jar:?]
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140) ~[guava-33.0.0-jre.jar:?]
at com.google.common.collect.TransformedIterator.hasNext(TransformedIterator.java:46) ~[guava-33.0.0-jre.jar:?]
at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145) ~[guava-33.0.0-jre.jar:?]
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140) ~[guava-33.0.0-jre.jar:?]
at io.airbyte.cdk.integrations.source.relationaldb.StateDecoratingIterator.computeNext(StateDecoratingIterator.java:127) ~[airbyte-cdk-db-sources-0.20.4.jar:?]
at io.airbyte.cdk.integrations.source.relationaldb.StateDecoratingIterator.computeNext(StateDecoratingIterator.java:22) ~[airbyte-cdk-db-sources-0.20.4.jar:?]
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145) ~[guava-33.0.0-jre.jar:?]
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140) ~[guava-33.0.0-jre.jar:?]
at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145) ~[guava-33.0.0-jre.jar:?]
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140) ~[guava-33.0.0-jre.jar:?]
at com.google.common.collect.TransformedIterator.hasNext(TransformedIterator.java:46) ~[guava-33.0.0-jre.jar:?]
at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145) ~[guava-33.0.0-jre.jar:?]
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140) ~[guava-33.0.0-jre.jar:?]
at io.airbyte.commons.util.CompositeIterator.computeNext(CompositeIterator.java:74) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145) ~[guava-33.0.0-jre.jar:?]
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140) ~[guava-33.0.0-jre.jar:?]
at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145) ~[guava-33.0.0-jre.jar:?]
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140) ~[guava-33.0.0-jre.jar:?]
at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145) ~[guava-33.0.0-jre.jar:?]
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140) ~[guava-33.0.0-jre.jar:?]
at java.base/java.util.Iterator.forEachRemaining(Iterator.java:132) ~[?:?]
at io.airbyte.cdk.integrations.base.IntegrationRunner.produceMessages(IntegrationRunner.java:236) ~[airbyte-cdk-core-0.20.4.jar:?]
at io.airbyte.cdk.integrations.base.IntegrationRunner.readSerial(IntegrationRunner.java:276) ~[airbyte-cdk-core-0.20.4.jar:?]
... 3 more

Stack Trace: java.lang.RuntimeException: java.sql.SQLException: java.io.IOException: Premature EOF
at io.airbyte.cdk.db.jdbc.StreamingJdbcDatabase.lambda$unsafeQuery$0(StreamingJdbcDatabase.java:77)
at java.base/java.util.stream.AbstractPipeline.close(AbstractPipeline.java:323)
at io.airbyte.commons.concurrency.VoidCallable.call(VoidCallable.java:15)
at io.airbyte.commons.util.DefaultAutoCloseableIterator.close(DefaultAutoCloseableIterator.java:53)
at io.airbyte.commons.util.LazyAutoCloseableIterator.close(LazyAutoCloseableIterator.java:56)
at io.airbyte.commons.concurrency.VoidCallable.call(VoidCallable.java:15)
at io.airbyte.commons.util.DefaultAutoCloseableIterator.close(DefaultAutoCloseableIterator.java:53)
at io.airbyte.commons.concurrency.VoidCallable.call(VoidCallable.java:15)
at io.airbyte.commons.util.DefaultAutoCloseableIterator.close(DefaultAutoCloseableIterator.java:53)
at io.airbyte.commons.concurrency.VoidCallable.call(VoidCallable.java:15)
at io.airbyte.commons.util.DefaultAutoCloseableIterator.close(DefaultAutoCloseableIterator.java:53)
at io.airbyte.commons.util.CompositeIterator.close(CompositeIterator.java:124)
at io.airbyte.commons.util.AutoCloseableIterators.lambda$appendOnClose$0(AutoCloseableIterators.java:106)
at io.airbyte.commons.concurrency.VoidCallable.call(VoidCallable.java:15)
at io.airbyte.commons.util.DefaultAutoCloseableIterator.close(DefaultAutoCloseableIterator.java:53)
at io.airbyte.commons.util.AutoCloseableIterators.lambda$appendOnClose$0(AutoCloseableIterators.java:106)
at io.airbyte.commons.concurrency.VoidCallable.call(VoidCallable.java:15)
at io.airbyte.commons.util.DefaultAutoCloseableIterator.close(DefaultAutoCloseableIterator.java:53)
at io.airbyte.cdk.integrations.base.IntegrationRunner.readSerial(IntegrationRunner.java:275)
at io.airbyte.cdk.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:173)
at io.airbyte.cdk.integrations.base.IntegrationRunner.run(IntegrationRunner.java:125)
at io.airbyte.integrations.source.clickhouse.ClickHouseSource.main(ClickHouseSource.java:134)
Caused by: java.sql.SQLException: java.io.IOException: Premature EOF
at com.clickhouse.jdbc.SqlExceptionUtils.handle(SqlExceptionUtils.java:77)
at com.clickhouse.jdbc.ClickHouseResultSet.next(ClickHouseResultSet.java:716)
at com.zaxxer.hikari.pool.HikariProxyResultSet.next(HikariProxyResultSet.java)
at io.airbyte.cdk.db.jdbc.StreamingJdbcDatabase$1.tryAdvance(StreamingJdbcDatabase.java:100)
at java.base/java.util.Spliterators$1Adapter.hasNext(Spliterators.java:681)
at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42)
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)
at io.airbyte.commons.util.LazyAutoCloseableIterator.computeNext(LazyAutoCloseableIterator.java:46)
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)
at com.google.common.collect.TransformedIterator.hasNext(TransformedIterator.java:46)
at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42)
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)
at io.airbyte.cdk.integrations.source.relationaldb.StateDecoratingIterator.computeNext(StateDecoratingIterator.java:127)
at io.airbyte.cdk.integrations.source.relationaldb.StateDecoratingIterator.computeNext(StateDecoratingIterator.java:22)
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)
at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42)
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)
at com.google.common.collect.TransformedIterator.hasNext(TransformedIterator.java:46)
at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42)
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)
at io.airbyte.commons.util.CompositeIterator.computeNext(CompositeIterator.java:74)
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)
at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42)
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)
at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42)
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)
at java.base/java.util.Iterator.forEachRemaining(Iterator.java:132)
at io.airbyte.cdk.integrations.base.IntegrationRunner.produceMessages(IntegrationRunner.java:236)
at io.airbyte.cdk.integrations.base.IntegrationRunner.readSerial(IntegrationRunner.java:276)
... 3 more
Caused by: java.io.IOException: Premature EOF
at java.base/sun.net.www.http.ChunkedInputStream.readAheadBlocking(ChunkedInputStream.java:567)
at java.base/sun.net.www.http.ChunkedInputStream.readAhead(ChunkedInputStream.java:611)
at java.base/sun.net.www.http.ChunkedInputStream.read(ChunkedInputStream.java:705)
at java.base/java.io.FilterInputStream.read(FilterInputStream.java:119)
at java.base/sun.net.www.protocol.http.HttpURLConnection$HttpInputStream.read(HttpURLConnection.java:3692)
at com.clickhouse.client.stream.Lz4InputStream.readFully(Lz4InputStream.java:34)
at com.clickhouse.client.stream.Lz4InputStream.updateBuffer(Lz4InputStream.java:72)
at com.clickhouse.client.stream.AbstractByteArrayInputStream.ensureOpen(AbstractByteArrayInputStream.java:36)
at com.clickhouse.client.stream.AbstractByteArrayInputStream.readByte(AbstractByteArrayInputStream.java:214)
at com.clickhouse.client.data.ClickHouseRowBinaryProcessor$MappedFunctions.lambda$buildMappingsForDataTypes$10(ClickHouseRowBinaryProcessor.java:208)
at com.clickhouse.client.data.ClickHouseRowBinaryProcessor$MappedFunctions.deserialize(ClickHouseRowBinaryProcessor.java:466)
at com.clickhouse.client.data.ClickHouseRowBinaryProcessor.readAndFill(ClickHouseRowBinaryProcessor.java:509)
at com.clickhouse.client.ClickHouseDataProcessor.nextRecord(ClickHouseDataProcessor.java:143)
at com.clickhouse.client.ClickHouseDataProcessor.access$100(ClickHouseDataProcessor.java:21)
at com.clickhouse.client.ClickHouseDataProcessor$RecordsIterator.next(ClickHouseDataProcessor.java:36)
at com.clickhouse.client.ClickHouseDataProcessor$RecordsIterator.next(ClickHouseDataProcessor.java:22)
at com.clickhouse.jdbc.ClickHouseResultSet.next(ClickHouseResultSet.java:714)
... 39 more

2025-11-14 14:01:55 source > ERROR i.a.c.i.b.AirbyteExceptionHandler(uncaughtException):64 Something went wrong in the connector. See the logs for more details. java.lang.RuntimeException: java.sql.SQLException: java.io.IOException: Premature EOF
at io.airbyte.cdk.db.jdbc.StreamingJdbcDatabase$1.tryAdvance(StreamingJdbcDatabase.java:112) ~[airbyte-cdk-core-0.20.4.jar:?]
at java.base/java.util.Spliterators$1Adapter.hasNext(Spliterators.java:681) ~[?:?]
at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145) ~[guava-33.0.0-jre.jar:?]
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140) ~[guava-33.0.0-jre.jar:?]
at io.airbyte.commons.util.LazyAutoCloseableIterator.computeNext(LazyAutoCloseableIterator.java:46) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145) ~[guava-33.0.0-jre.jar:?]
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140) ~[guava-33.0.0-jre.jar:?]
at com.google.common.collect.TransformedIterator.hasNext(TransformedIterator.java:46) ~[guava-33.0.0-jre.jar:?]
at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145) ~[guava-33.0.0-jre.jar:?]
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140) ~[guava-33.0.0-jre.jar:?]
at io.airbyte.cdk.integrations.source.relationaldb.StateDecoratingIterator.computeNext(StateDecoratingIterator.java:127) ~[airbyte-cdk-db-sources-0.20.4.jar:?]
at io.airbyte.cdk.integrations.source.relationaldb.StateDecoratingIterator.computeNext(StateDecoratingIterator.java:22) ~[airbyte-cdk-db-sources-0.20.4.jar:?]
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145) ~[guava-33.0.0-jre.jar:?]
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140) ~[guava-33.0.0-jre.jar:?]
at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145) ~[guava-33.0.0-jre.jar:?]
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140) ~[guava-33.0.0-jre.jar:?]
at com.google.common.collect.TransformedIterator.hasNext(TransformedIterator.java:46) ~[guava-33.0.0-jre.jar:?]
at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145) ~[guava-33.0.0-jre.jar:?]
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140) ~[guava-33.0.0-jre.jar:?]
at io.airbyte.commons.util.CompositeIterator.computeNext(CompositeIterator.java:74) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145) ~[guava-33.0.0-jre.jar:?]
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140) ~[guava-33.0.0-jre.jar:?]
at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145) ~[guava-33.0.0-jre.jar:?]
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140) ~[guava-33.0.0-jre.jar:?]
at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145) ~[guava-33.0.0-jre.jar:?]
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140) ~[guava-33.0.0-jre.jar:?]
at java.base/java.util.Iterator.forEachRemaining(Iterator.java:132) ~[?:?]
at io.airbyte.cdk.integrations.base.IntegrationRunner.produceMessages(IntegrationRunner.java:236) ~[airbyte-cdk-core-0.20.4.jar:?]
at io.airbyte.cdk.integrations.base.IntegrationRunner.readSerial(IntegrationRunner.java:276) ~[airbyte-cdk-core-0.20.4.jar:?]
at io.airbyte.cdk.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:173) ~[airbyte-cdk-core-0.20.4.jar:?]
at io.airbyte.cdk.integrations.base.IntegrationRunner.run(IntegrationRunner.java:125) ~[airbyte-cdk-core-0.20.4.jar:?]
at io.airbyte.integrations.source.clickhouse.ClickHouseSource.main(ClickHouseSource.java:134) ~[io.airbyte.airbyte-integrations.connectors-source-clickhouse.jar:?]
Suppressed: java.lang.RuntimeException: java.sql.SQLException: java.io.IOException: Premature EOF
at io.airbyte.cdk.db.jdbc.StreamingJdbcDatabase.lambda$unsafeQuery$0(StreamingJdbcDatabase.java:77) ~[airbyte-cdk-core-0.20.4.jar:?]
at java.base/java.util.stream.AbstractPipeline.close(AbstractPipeline.java:323) ~[?:?]
at io.airbyte.commons.concurrency.VoidCallable.call(VoidCallable.java:15) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at io.airbyte.commons.util.DefaultAutoCloseableIterator.close(DefaultAutoCloseableIterator.java:53) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at io.airbyte.commons.util.LazyAutoCloseableIterator.close(LazyAutoCloseableIterator.java:56) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at io.airbyte.commons.concurrency.VoidCallable.call(VoidCallable.java:15) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at io.airbyte.commons.util.DefaultAutoCloseableIterator.close(DefaultAutoCloseableIterator.java:53) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at io.airbyte.commons.concurrency.VoidCallable.call(VoidCallable.java:15) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at io.airbyte.commons.util.DefaultAutoCloseableIterator.close(DefaultAutoCloseableIterator.java:53) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at io.airbyte.commons.concurrency.VoidCallable.call(VoidCallable.java:15) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at io.airbyte.commons.util.DefaultAutoCloseableIterator.close(DefaultAutoCloseableIterator.java:53) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at io.airbyte.commons.util.CompositeIterator.close(CompositeIterator.java:124) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at io.airbyte.commons.util.AutoCloseableIterators.lambda$appendOnClose$0(AutoCloseableIterators.java:106) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at io.airbyte.commons.concurrency.VoidCallable.call(VoidCallable.java:15) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at io.airbyte.commons.util.DefaultAutoCloseableIterator.close(DefaultAutoCloseableIterator.java:53) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at io.airbyte.commons.util.AutoCloseableIterators.lambda$appendOnClose$0(AutoCloseableIterators.java:106) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at io.airbyte.commons.concurrency.VoidCallable.call(VoidCallable.java:15) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at io.airbyte.commons.util.DefaultAutoCloseableIterator.close(DefaultAutoCloseableIterator.java:53) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at io.airbyte.cdk.integrations.base.IntegrationRunner.readSerial(IntegrationRunner.java:275) ~[airbyte-cdk-core-0.20.4.jar:?]
at io.airbyte.cdk.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:173) ~[airbyte-cdk-core-0.20.4.jar:?]
at io.airbyte.cdk.integrations.base.IntegrationRunner.run(IntegrationRunner.java:125) ~[airbyte-cdk-core-0.20.4.jar:?]
at io.airbyte.integrations.source.clickhouse.ClickHouseSource.main(ClickHouseSource.java:134) ~[io.airbyte.airbyte-integrations.connectors-source-clickhouse.jar:?]
Caused by: java.sql.SQLException: java.io.IOException: Premature EOF
at com.clickhouse.jdbc.SqlExceptionUtils.handle(SqlExceptionUtils.java:77) ~[clickhouse-jdbc-0.3.2-patch10-all.jar:clickhouse-jdbc 0.3.2-patch10 (revision: aebad16)]
at com.clickhouse.jdbc.ClickHouseResultSet.next(ClickHouseResultSet.java:716) ~[clickhouse-jdbc-0.3.2-patch10-all.jar:clickhouse-jdbc 0.3.2-patch10 (revision: aebad16)]
at com.zaxxer.hikari.pool.HikariProxyResultSet.next(HikariProxyResultSet.java) ~[HikariCP-5.1.0.jar:?]
at io.airbyte.cdk.db.jdbc.StreamingJdbcDatabase$1.tryAdvance(StreamingJdbcDatabase.java:100) ~[airbyte-cdk-core-0.20.4.jar:?]
at java.base/java.util.Spliterators$1Adapter.hasNext(Spliterators.java:681) ~[?:?]
at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145) ~[guava-33.0.0-jre.jar:?]
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140) ~[guava-33.0.0-jre.jar:?]
at io.airbyte.commons.util.LazyAutoCloseableIterator.computeNext(LazyAutoCloseableIterator.java:46) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145) ~[guava-33.0.0-jre.jar:?]
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140) ~[guava-33.0.0-jre.jar:?]
at com.google.common.collect.TransformedIterator.hasNext(TransformedIterator.java:46) ~[guava-33.0.0-jre.jar:?]
at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145) ~[guava-33.0.0-jre.jar:?]
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140) ~[guava-33.0.0-jre.jar:?]
at io.airbyte.cdk.integrations.source.relationaldb.StateDecoratingIterator.computeNext(StateDecoratingIterator.java:127) ~[airbyte-cdk-db-sources-0.20.4.jar:?]
at io.airbyte.cdk.integrations.source.relationaldb.StateDecoratingIterator.computeNext(StateDecoratingIterator.java:22) ~[airbyte-cdk-db-sources-0.20.4.jar:?]
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145) ~[guava-33.0.0-jre.jar:?]
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140) ~[guava-33.0.0-jre.jar:?]
at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145) ~[guava-33.0.0-jre.jar:?]
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140) ~[guava-33.0.0-jre.jar:?]
at com.google.common.collect.TransformedIterator.hasNext(TransformedIterator.java:46) ~[guava-33.0.0-jre.jar:?]
at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145) ~[guava-33.0.0-jre.jar:?]
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140) ~[guava-33.0.0-jre.jar:?]
at io.airbyte.commons.util.CompositeIterator.computeNext(CompositeIterator.java:74) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145) ~[guava-33.0.0-jre.jar:?]
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140) ~[guava-33.0.0-jre.jar:?]
at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145) ~[guava-33.0.0-jre.jar:?]
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140) ~[guava-33.0.0-jre.jar:?]
at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42) ~[airbyte-cdk-dependencies-0.20.4.jar:?]
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145) ~[guava-33.0.0-jre.jar:?]
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140) ~[guava-33.0.0-jre.jar:?]
at java.base/java.util.Iterator.forEachRemaining(Iterator.java:132) ~[?:?]
at io.airbyte.cdk.integrations.base.IntegrationRunner.produceMessages(IntegrationRunner.java:236) ~[airbyte-cdk-core-0.20.4.jar:?]
at io.airbyte.cdk.integrations.base.IntegrationRunner.readSerial(IntegrationRunner.java:276) ~[airbyte-cdk-core-0.20.4.jar:?]
... 3 more
Caused by: java.io.IOException: Premature EOF
at java.base/sun.net.www.http.ChunkedInputStream.readAheadBlocking(ChunkedInputStream.java:567) ~[?:?]
at java.base/sun.net.www.http.ChunkedInputStream.readAhead(ChunkedInputStream.java:611) ~[?:?]
at java.base/sun.net.www.http.ChunkedInputStream.read(ChunkedInputStream.java:705) ~[?:?]
at java.base/java.io.FilterInputStream.read(FilterInputStream.java:119) ~[?:?]
at java.base/sun.net.www.protocol.http.HttpURLConnection$HttpInputStream.read(HttpURLConnection.java:3692) ~[?:?]
at com.clickhouse.client.stream.Lz4InputStream.readFully(Lz4InputStream.java:34) ~[clickhouse-jdbc-0.3.2-patch10-all.jar:clickhouse-jdbc 0.3.2-patch10 (revision: aebad16)]
at com.clickhouse.client.stream.Lz4InputStream.updateBuffer(Lz4InputStream.java:72) ~[clickhouse-jdbc-0.3.2-patch10-all.jar:clickhouse-jdbc 0.3.2-patch10 (revision: aebad16)]
at com.clickhouse.client.stream.AbstractByteArrayInputStream.ensureOpen(AbstractByteArrayInputStream.java:36) ~[clickhouse-jdbc-0.3.2-patch10-all.jar:clickhouse-jdbc 0.3.2-patch10 (revision: aebad16)]
at com.clickhouse.client.stream.AbstractByteArrayInputStream.readByte(AbstractByteArrayInputStream.java:214) ~[clickhouse-jdbc-0.3.2-patch10-all.jar:clickhouse-jdbc 0.3.2-patch10 (revision: aebad16)]
at com.clickhouse.client.data.ClickHouseRowBinaryProcessor$MappedFunctions.lambda$buildMappingsForDataTypes$10(ClickHouseRowBinaryProcessor.java:208) ~[clickhouse-jdbc-0.3.2-patch10-all.jar:clickhouse-jdbc 0.3.2-patch10 (revision: aebad16)]
at com.clickhouse.client.data.ClickHouseRowBinaryProcessor$MappedFunctions.deserialize(ClickHouseRowBinaryProcessor.java:466) ~[clickhouse-jdbc-0.3.2-patch10-all.jar:clickhouse-jdbc 0.3.2-patch10 (revision: aebad16)]
at com.clickhouse.client.data.ClickHouseRowBinaryProcessor.readAndFill(ClickHouseRowBinaryProcessor.java:509) ~[clickhouse-jdbc-0.3.2-patch10-all.jar:clickhouse-jdbc 0.3.2-patch10 (revision: aebad16)]
at com.clickhouse.client.ClickHouseDataProcessor.nextRecord(ClickHouseDataProcessor.java:143) ~[clickhouse-jdbc-0.3.2-patch10-all.jar:clickhouse-jdbc 0.3.2-patch10 (revision: aebad16)]
at com.clickhouse.client.ClickHouseDataProcessor.access$100(ClickHouseDataProcessor.java:21) ~[clickhouse-jdbc-0.3.2-patch10-all.jar:clickhouse-jdbc 0.3.2-patch10 (revision: aebad16)]
at com.clickhouse.client.ClickHouseDataProcessor$RecordsIterator.next(ClickHouseDataProcessor.java:36) ~[clickhouse-jdbc-0.3.2-patch10-all.jar:clickhouse-jdbc 0.3.2-patch10 (revision: aebad16)]
at com.clickhouse.client.ClickHouseDataProcessor$RecordsIterator.next(ClickHouseDataProcessor.java:22) ~[clickhouse-jdbc-0.3.2-patch10-all.jar:clickhouse-jdbc 0.3.2-patch10 (revision: aebad16)]
at com.clickhouse.jdbc.ClickHouseResultSet.next(ClickHouseResultSet.java:714) ~[clickhouse-jdbc-0.3.2-patch10-all.jar:clickhouse-jdbc 0.3.2-patch10 (revision: aebad16)]
at com.zaxxer.hikari.pool.HikariProxyResultSet.next(HikariProxyResultSet.java) ~[HikariCP-5.1.0.jar:?]
at io.airbyte.cdk.db.jdbc.StreamingJdbcDatabase$1.tryAdvance(StreamingJdbcDatabase.java:100) ~[airbyte-cdk-core-0.20.4.jar:?]
at java.base/java.util.Spliterators$1Adapter.hasNext(Spliterators.java:681) ~[?:?]
at io.airbyte.commons.util.DefaultAutoCloseableIterator.comp…
Stack Trace: java.lang.RuntimeException: java.sql.SQLException: java.io.IOException: Premature EOF
at io.airbyte.cdk.db.jdbc.StreamingJdbcDatabase$1.tryAdvance(StreamingJdbcDatabase.java:112)
at java.base/java.util.Spliterators$1Adapter.hasNext(Spliterators.java:681)
at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42)
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)
at io.airbyte.commons.util.LazyAutoCloseableIterator.computeNext(LazyAutoCloseableIterator.java:46)
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)
at com.google.common.collect.TransformedIterator.hasNext(TransformedIterator.java:46)
at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42)
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)
at io.airbyte.cdk.integrations.source.relationaldb.StateDecoratingIterator.computeNext(StateDecoratingIterator.java:127)
at io.airbyte.cdk.integrations.source.relationaldb.StateDecoratingIterator.computeNext(StateDecoratingIterator.java:22)
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)
at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42)
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)
at com.google.common.collect.TransformedIterator.hasNext(TransformedIterator.java:46)
at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42)
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)
at io.airbyte.commons.util.CompositeIterator.computeNext(CompositeIterator.java:74)
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)
at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42)
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)
at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42)
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)
at java.base/java.util.Iterator.forEachRemaining(Iterator.java:132)
at io.airbyte.cdk.integrations.base.IntegrationRunner.produceMessages(IntegrationRunner.java:236)
at io.airbyte.cdk.integrations.base.IntegrationRunner.readSerial(IntegrationRunner.java:276)
at io.airbyte.cdk.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:173)
at io.airbyte.cdk.integrations.base.IntegrationRunner.run(IntegrationRunner.java:125)
at io.airbyte.integrations.source.clickhouse.ClickHouseSource.main(ClickHouseSource.java:134)
Suppressed: java.lang.RuntimeException: java.sql.SQLException: java.io.IOException: Premature EOF
at io.airbyte.cdk.db.jdbc.StreamingJdbcDatabase.lambda$unsafeQuery$0(StreamingJdbcDatabase.java:77)
at java.base/java.util.stream.AbstractPipeline.close(AbstractPipeline.java:323)
at io.airbyte.commons.concurrency.VoidCallable.call(VoidCallable.java:15)
at io.airbyte.commons.util.DefaultAutoCloseableIterator.close(DefaultAutoCloseableIterator.java:53)
at io.airbyte.commons.util.LazyAutoCloseableIterator.close(LazyAutoCloseableIterator.java:56)
at io.airbyte.commons.concurrency.VoidCallable.call(VoidCallable.java:15)
at io.airbyte.commons.util.DefaultAutoCloseableIterator.close(DefaultAutoCloseableIterator.java:53)
at io.airbyte.commons.concurrency.VoidCallable.call(VoidCallable.java:15)
at io.airbyte.commons.util.DefaultAutoCloseableIterator.close(DefaultAutoCloseableIterator.java:53)
at io.airbyte.commons.concurrency.VoidCallable.call(VoidCallable.java:15)
at io.airbyte.commons.util.DefaultAutoCloseableIterator.close(DefaultAutoCloseableIterator.java:53)
at io.airbyte.commons.util.CompositeIterator.close(CompositeIterator.java:124)
at io.airbyte.commons.util.AutoCloseableIterators.lambda$appendOnClose$0(AutoCloseableIterators.java:106)
at io.airbyte.commons.concurrency.VoidCallable.call(VoidCallable.java:15)
at io.airbyte.commons.util.DefaultAutoCloseableIterator.close(DefaultAutoCloseableIterator.java:53)
at io.airbyte.commons.util.AutoCloseableIterators.lambda$appendOnClose$0(AutoCloseableIterators.java:106)
at io.airbyte.commons.concurrency.VoidCallable.call(VoidCallable.java:15)
at io.airbyte.commons.util.DefaultAutoCloseableIterator.close(DefaultAutoCloseableIterator.java:53)
at io.airbyte.cdk.integrations.base.IntegrationRunner.readSerial(IntegrationRunner.java:275)
... 3 more
Caused by: java.sql.SQLException: java.io.IOException: Premature EOF
at com.clickhouse.jdbc.SqlExceptionUtils.handle(SqlExceptionUtils.java:77)
at com.clickhouse.jdbc.ClickHouseResultSet.next(ClickHouseResultSet.java:716)
at com.zaxxer.hikari.pool.HikariProxyResultSet.next(HikariProxyResultSet.java)
at io.airbyte.cdk.db.jdbc.StreamingJdbcDatabase$1.tryAdvance(StreamingJdbcDatabase.java:100)
at java.base/java.util.Spliterators$1Adapter.hasNext(Spliterators.java:681)
at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42)
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)
at io.airbyte.commons.util.LazyAutoCloseableIterator.computeNext(LazyAutoCloseableIterator.java:46)
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)
at com.google.common.collect.TransformedIterator.hasNext(TransformedIterator.java:46)
at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42)
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)
at io.airbyte.cdk.integrations.source.relationaldb.StateDecoratingIterator.computeNext(StateDecoratingIterator.java:127)
at io.airbyte.cdk.integrations.source.relationaldb.StateDecoratingIterator.computeNext(StateDecoratingIterator.java:22)
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)
at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42)
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)
at com.google.common.collect.TransformedIterator.hasNext(TransformedIterator.java:46)
at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42)
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)
at io.airbyte.commons.util.CompositeIterator.computeNext(CompositeIterator.java:74)
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)
at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42)
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)
at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42)
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)
at java.base/java.util.Iterator.forEachRemaining(Iterator.java:132)
at io.airbyte.cdk.integrations.base.IntegrationRunner.produceMessages(IntegrationRunner.java:236)
at io.airbyte.cdk.integrations.base.IntegrationRunner.readSerial(IntegrationRunner.java:276)
... 3 more
Caused by: java.io.IOException: Premature EOF
at java.base/sun.net.www.http.ChunkedInputStream.readAheadBlocking(ChunkedInputStream.java:567)
at java.base/sun.net.www.http.ChunkedInputStream.readAhead(ChunkedInputStream.java:611)
at java.base/sun.net.www.http.ChunkedInputStream.read(ChunkedInputStream.java:705)
at java.base/java.io.FilterInputStream.read(FilterInputStream.java:119)
at java.base/sun.net.www.protocol.http.HttpURLConnection$HttpInputStream.read(HttpURLConnection.java:3692)
at com.clickhouse.client.stream.Lz4InputStream.readFully(Lz4InputStream.java:34)
at com.clickhouse.client.stream.Lz4InputStream.updateBuffer(Lz4InputStream.java:72)
at com.clickhouse.client.stream.AbstractByteArrayInputStream.ensureOpen(AbstractByteArrayInputStream.java:36)
at com.clickhouse.client.stream.AbstractByteArrayInputStream.readByte(AbstractByteArrayInputStream.java:214)
at com.clickhouse.client.data.ClickHouseRowBinaryProcessor$MappedFunctions.lambda$buildMappingsForDataTypes$10(ClickHouseRowBinaryProcessor.java:208)
at com.clickhouse.client.data.ClickHouseRowBinaryProcessor$MappedFunctions.deserialize(ClickHouseRowBinaryProcessor.java:466)
at com.clickhouse.client.data.ClickHouseRowBinaryProcessor.readAndFill(ClickHouseRowBinaryProcessor.java:509)
at com.clickhouse.client.ClickHouseDataProcessor.nextRecord(ClickHouseDataProcessor.java:143)
at com.clickhouse.client.ClickHouseDataProcessor.access$100(ClickHouseDataProcessor.java:21)
at com.clickhouse.client.ClickHouseDataProcessor$RecordsIterator.next(ClickHouseDataProcessor.java:36)
at com.clickhouse.client.ClickHouseDataProcessor$RecordsIterator.next(ClickHouseDataProcessor.java:22)
at com.clickhouse.jdbc.ClickHouseResultSet.next(ClickHouseResultSet.java:714)
... 39 more
Caused by: [CIRCULAR REFERENCE: java.sql.SQLException: java.io.IOException: Premature EOF]
```

### Contribute

- [ ] Yes, I want to contribute