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

Connection reset from SQLServer causes debezium connector to stop reading records.

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Cannot Reproduce
    • Icon: Major Major
    • None
    • 1.3.1.Final
    • sqlserver-connector
    • None
    • False
    • False
    • Undefined

      When connection reset happens from the SQL server following exception can be seen in the logs

      2021-01-11 06:57:51,543 - ERROR [debezium-sqlserverconnector-dummy-change-event-source-coordinator:i.d.p.ErrorHandler@31] - Producer failure
      com.microsoft.sqlserver.jdbc.SQLServerException: Connection reset
      	at com.microsoft.sqlserver.jdbc.SQLServerConnection.terminate(SQLServerConnection.java:2998) ~[mssql-jdbc-6.2.1.jre7.jar:na]
      	at com.microsoft.sqlserver.jdbc.TDSChannel.read(IOBuffer.java:2034) ~[mssql-jdbc-6.2.1.jre7.jar:na]
      	at com.microsoft.sqlserver.jdbc.TDSReader.readPacket(IOBuffer.java:6446) ~[mssql-jdbc-6.2.1.jre7.jar:na]
      	at com.microsoft.sqlserver.jdbc.TDSCommand.startResponse(IOBuffer.java:7610) ~[mssql-jdbc-6.2.1.jre7.jar:na]
      	at com.microsoft.sqlserver.jdbc.SQLServerStatement.doExecuteStatement(SQLServerStatement.java:870) ~[mssql-jdbc-6.2.1.jre7.jar:na]
      	at com.microsoft.sqlserver.jdbc.SQLServerStatement$StmtExecCmd.doExecute(SQLServerStatement.java:767) ~[mssql-jdbc-6.2.1.jre7.jar:na]
      	at com.microsoft.sqlserver.jdbc.TDSCommand.execute(IOBuffer.java:7225) ~[mssql-jdbc-6.2.1.jre7.jar:na]
      	at com.microsoft.sqlserver.jdbc.SQLServerConnection.executeCommand(SQLServerConnection.java:3053) ~[mssql-jdbc-6.2.1.jre7.jar:na]
      	at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeCommand(SQLServerStatement.java:247) ~[mssql-jdbc-6.2.1.jre7.jar:na]
      	at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeStatement(SQLServerStatement.java:222) ~[mssql-jdbc-6.2.1.jre7.jar:na]
      	at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeQuery(SQLServerStatement.java:692) ~[mssql-jdbc-6.2.1.jre7.jar:na]
      	at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:634) ~[debezium-core-1.3.1.Final.jar:1.3.1.Final]
      	at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:503) ~[debezium-core-1.3.1.Final.jar:1.3.1.Final]
      	at io.debezium.connector.sqlserver.SqlServerConnection.getMaxLsn(SqlServerConnection.java:151) ~[1610344172921-0/:na]
      	at io.debezium.connector.sqlserver.SqlServerStreamingChangeEventSource.execute(SqlServerStreamingChangeEventSource.java:128) ~[1610344172921-0/:na]
      	at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:140) [debezium-core-1.3.1.Final.jar:1.3.1.Final]
      	at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:113) [debezium-core-1.3.1.Final.jar:1.3.1.Final]
      	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) ~[na:1.8.0_275]
      	at java.util.concurrent.FutureTask.run(FutureTask.java:266) ~[na:1.8.0_275]
      	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[na:1.8.0_275]
      	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[na:1.8.0_275]
      	at java.lang.Thread.run(Thread.java:748) ~[na:1.8.0_275]
      Caused by: java.net.SocketException: Connection reset
      	at java.net.SocketInputStream.read(SocketInputStream.java:210) ~[na:1.8.0_275]
      	at java.net.SocketInputStream.read(SocketInputStream.java:141) ~[na:1.8.0_275]
      	at com.microsoft.sqlserver.jdbc.TDSChannel.read(IOBuffer.java:2026) ~[mssql-jdbc-6.2.1.jre7.jar:na]
      	... 20 common frames omitted
      2021-01-11 06:57:51,549 - ERROR [debezium-sqlserverconnector-dummy-change-event-source-coordinator:i.d.p.ErrorHandler@31] - Producer failure
      java.lang.NoClassDefFoundError: com/microsoft/sqlserver/jdbc/SQLServerException
      	at io.debezium.connector.sqlserver.SqlServerErrorHandler.isRetriable(SqlServerErrorHandler.java:26) ~[1610344172921-0/:na]
      	at io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:34) ~[debezium-core-1.3.1.Final.jar:1.3.1.Final]
      	at io.debezium.connector.sqlserver.SqlServerStreamingChangeEventSource.execute(SqlServerStreamingChangeEventSource.java:283) ~[1610344172921-0/:na]
      	at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:140) ~[debezium-core-1.3.1.Final.jar:1.3.1.Final]
      	at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:113) ~[debezium-core-1.3.1.Final.jar:1.3.1.Final]
      	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) ~[na:1.8.0_275]
      	at java.util.concurrent.FutureTask.run(FutureTask.java:266) ~[na:1.8.0_275]
      	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[na:1.8.0_275]
      	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[na:1.8.0_275]
      	at java.lang.Thread.run(Thread.java:748) ~[na:1.8.0_275]
      Caused by: java.lang.ClassNotFoundException: com.microsoft.sqlserver.jdbc.SQLServerException
      	at java.net.URLClassLoader.findClass(URLClassLoader.java:382) ~[na:1.8.0_275]
      	at io.cdap.cdap.common.lang.InterceptableClassLoader.findClass(InterceptableClassLoader.java:44) ~[na:na]
      	at java.lang.ClassLoader.loadClass(ClassLoader.java:418) ~[na:1.8.0_275]
      	at java.lang.ClassLoader.loadClass(ClassLoader.java:351) ~[na:1.8.0_275]
      	... 10 common frames omitted 
      2021-01-11 06:57:51,549 - INFO  [debezium-sqlserverconnector-dummy-change-event-source-coordinator:i.d.p.m.StreamingChangeEventSourceMetrics@60] - Connected metrics set to 'false'

       

              Unassigned Unassigned
              sagarkapare Sagar Kapare (Inactive)
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

                Created:
                Updated:
                Resolved: