Summary
User reports a sync error occurring after upgrading the Postgres connector, with stack trace indicating a SocketException and I/O error while sending to the backend.
Question
Hello Team,
I just started having this error on all my syncs after upgrading the Postgres connector:
at io.airbyte.commons.util.DefaultAutoCloseableIterator.computeNext(DefaultAutoCloseableIterator.java:42)
1401
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:145)
1402
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:140)
1403
at java.base/java.util.Iterator.forEachRemaining(Iterator.java:132)
1404
at io.airbyte.cdk.integrations.base.IntegrationRunner.produceMessages(IntegrationRunner.java:232)
1405
at io.airbyte.cdk.integrations.base.IntegrationRunner.readSerial(IntegrationRunner.java:268)
1406
at io.airbyte.cdk.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:173)
1407
at io.airbyte.cdk.integrations.base.IntegrationRunner.run(IntegrationRunner.java:125)
1408
at io.airbyte.integrations.source.postgres.PostgresSource.main(PostgresSource.java:713)
1409
Caused by: java.net.SocketException: Connection reset
1410
at java.base/sun.nio.ch.NioSocketImpl.implRead(NioSocketImpl.java:318)
1411
at java.base/sun.nio.ch.NioSocketImpl.read(NioSocketImpl.java:346)
1412
at java.base/sun.nio.ch.NioSocketImpl$1.read(NioSocketImpl.java:796)
1413
at java.base/java.net.Socket$SocketInputStream.read(Socket.java:1099)
1414
at org.postgresql.core.VisibleBufferedInputStream.readMore(VisibleBufferedInputStream.java:161)
1415
at org.postgresql.core.VisibleBufferedInputStream.ensureBytes(VisibleBufferedInputStream.java:128)
1416
at org.postgresql.core.VisibleBufferedInputStream.ensureBytes(VisibleBufferedInputStream.java:113)
1417
at org.postgresql.core.VisibleBufferedInputStream.read(VisibleBufferedInputStream.java:73)
1418
at org.postgresql.core.PGStream.receiveChar(PGStream.java:465)
1419
at org.postgresql.core.v3.QueryExecutorImpl.processResults(QueryExecutorImpl.java:2155)
1420
at org.postgresql.core.v3.QueryExecutorImpl.fetch(QueryExecutorImpl.java:2598)
1421
… 40 more
1422
1423
2024-03-08 11:38:14 source > ERROR main i.a.c.d.j.StreamingJdbcDatabase$1(tryAdvance):109 SQLState: 08006, Message: An I/O error occurred while sending to the backend.
1424
2024-03-08 11:38:14 source > ERROR main i.a.c.u.CompositeIterator(close):126 exception while closing java.lang.RuntimeException: java.sql.SQLException: Connection is closed
1425
at io.airbyte.cdk.db.jdbc.StreamingJdbcDatabase.lambda$unsafeQuery$0(StreamingJdbcDatabase.java:80) ~[airbyte-cdk-core-0.23.16.jar:?]
1426
at java.base/java.util.stream.AbstractPipeline.close(AbstractPipeline.java:323) ~[?:?]
This topic has been created from a Slack thread to give it more visibility.
It will be on Read-Only mode here. Click here if you want
to access the original thread.