Uploaded image for project: 'Debezium'
  1. Debezium
  2. DBZ-2727

Connection timeout on write should retry

XMLWordPrintable

      State:  FAILED
            Trace:  

      org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped.
                    at io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:42)
                    at io.debezium.connector.sqlserver.SqlServerStreamingChangeEventSource.execute(SqlServerStreamingChangeEventSource.java:283)
                    at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:140)
                    at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:113)
                    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
                    at java.util.concurrent.FutureTask.run(FutureTask.java:266)
                    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
                    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
                    at java.lang.Thread.run(Thread.java:748)
      Caused by: com.microsoft.sqlserver.jdbc.SQLServerException: Connection timed out (Write failed)
        at com.microsoft.sqlserver.jdbc.SQLServerConnection.terminate(SQLServerConnection.java:2892)
        at com.microsoft.sqlserver.jdbc.TDSChannel.write(IOBuffer.java:2045)
        at com.microsoft.sqlserver.jdbc.TDSWriter.flush(IOBuffer.java:4146)
        at com.microsoft.sqlserver.jdbc.TDSWriter.writePacket(IOBuffer.java:4048)
        at com.microsoft.sqlserver.jdbc.TDSWriter.endMessage(IOBuffer.java:3185)
        at com.microsoft.sqlserver.jdbc.TDSCommand.startResponse(IOBuffer.java:7556)
        at com.microsoft.sqlserver.jdbc.SQLServerPreparedStatement.doExecutePreparedStatement(SQLServerPreparedStatement.java:590)
        at com.microsoft.sqlserver.jdbc.SQLServerPreparedStatement$PrepStmtExecCmd.doExecute(SQLServerPreparedStatement.java:522)
        at com.microsoft.sqlserver.jdbc.TDSCommand.execute(IOBuffer.java:7194)
        at com.microsoft.sqlserver.jdbc.SQLServerConnection.executeCommand(SQLServerConnection.java:2935)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeCommand(SQLServerStatement.java:248)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeStatement(SQLServerStatement.java:223)
        at com.microsoft.sqlserver.jdbc.SQLServerPreparedStatement.executeQuery(SQLServerPreparedStatement.java:444)
        at io.debezium.jdbc.JdbcConnection.prepareQueryAndMap(JdbcConnection.java:720)
        at io.debezium.connector.sqlserver.SqlServerConnection.timestampOfLsn(SqlServerConnection.java:266)
        at io.debezium.connector.sqlserver.SqlServerStreamingChangeEventSource.lambda$execute$1(SqlServerStreamingChangeEventSource.java:259)
        at io.debezium.jdbc.JdbcConnection.prepareQuery(JdbcConnection.java:588)
        at io.debezium.connector.sqlserver.SqlServerConnection.getChangesForTables(SqlServerConnection.java:217)
        at io.debezium.connector.sqlserver.SqlServerStreamingChangeEventSource.execute(SqlServerStreamingChangeEventSource.java:164)
        ... 7 more
      Caused by: java.net.SocketException: Connection timed out (Write failed)
        at java.net.SocketOutputStream.socketWrite0(Native Method)
        at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:111)
        at java.net.SocketOutputStream.write(SocketOutputStream.java:155)
        at com.microsoft.sqlserver.jdbc.TDSChannel.write(IOBuffer.java:2040)
        ... 24 more
      

            worker_id:        240.0.21.21:8083
          Type:               source
        Observed Generation:  1
      Events:                 <none>
       

              Unassigned Unassigned
              pshussain Mohamed Pudukulathan (Inactive)
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

                Created:
                Updated:
                Resolved: