Connection reset Error While Loading from SQLServer to Snowflake

[RFAM1]

Hi,

I am trying to load a table from SQLserver to Snowflake. I am able to load a subset of the table e.g select top 1000 col1, col2, col3 from dbo.xxx; But when I try to load the entire table I am getting connection error.

It is not a huge table 3193377 is the count. From the same database I am able to load few other bigger tables.

Please help as it needs to be worked on ASAP.

Exception in component tDBInput_2 (j_ingestion_full_incr_sqlserverCF_to_snowflake)

com.microsoft.sqlserver.jdbc.SQLServerException: Connection reset ClientConnectionId:12ee0ddc-2925-490e-ada4-be057a363462

at com.microsoft.sqlserver.jdbc.SQLServerConnection.terminate(SQLServerConnection.java:2435)

at com.microsoft.sqlserver.jdbc.TDSChannel.read(IOBuffer.java:1991)

at com.microsoft.sqlserver.jdbc.TDSReader.readPacket(IOBuffer.java:6310)

at com.microsoft.sqlserver.jdbc.TDSCommand.startResponse(IOBuffer.java:7548)

at com.microsoft.sqlserver.jdbc.TDSCommand.startResponse(IOBuffer.java:7507)

at com.microsoft.sqlserver.jdbc.SQLServerConnection.sendFedAuthToken(SQLServerConnection.java:3712)

at com.microsoft.sqlserver.jdbc.SQLServerConnection.access$200(SQLServerConnection.java:82)

at com.microsoft.sqlserver.jdbc.SQLServerConnection$FedAuthTokenCommand.doExecute(SQLServerConnection.java:3563)

at com.microsoft.sqlserver.jdbc.TDSCommand.execute(IOBuffer.java:7151)

at com.microsoft.sqlserver.jdbc.SQLServerConnection.onFedAuthInfo(SQLServerConnection.java:3587)

at com.microsoft.sqlserver.jdbc.SQLServerConnection.processFedAuthInfo(SQLServerConnection.java:3548)

at com.microsoft.sqlserver.jdbc.TDSTokenHandler.onFedAuthInfo(tdsparser.java:261)

at com.microsoft.sqlserver.jdbc.TDSParser.parse(tdsparser.java:103)

at com.microsoft.sqlserver.jdbc.SQLServerConnection.sendLogon(SQLServerConnection.java:4290)

at com.microsoft.sqlserver.jdbc.SQLServerConnection.logon(SQLServerConnection.java:3157)

at com.microsoft.sqlserver.jdbc.SQLServerConnection.access$100(SQLServerConnection.java:82)

at com.microsoft.sqlserver.jdbc.SQLServerConnection$LogonCommand.doExecute(SQLServerConnection.java:3121)

at com.microsoft.sqlserver.jdbc.TDSCommand.execute(IOBuffer.java:7151)

at com.microsoft.sqlserver.jdbc.SQLServerConnection.executeCommand(SQLServerConnection.java:2478)

at com.microsoft.sqlserver.jdbc.SQLServerConnection.connectHelper(SQLServerConnection.java:2026)

at com.microsoft.sqlserver.jdbc.SQLServerConnection.login(SQLServerConnection.java:1687)

at com.microsoft.sqlserver.jdbc.SQLServerConnection.connectInternal(SQLServerConnection.java:1528)

at com.microsoft.sqlserver.jdbc.SQLServerConnection.connect(SQLServerConnection.java:866)

at com.microsoft.sqlserver.jdbc.SQLServerConnection.checkClosed(SQLServerConnection.java:801)

at com.microsoft.sqlserver.jdbc.SQLServerStatement.checkClosed(SQLServerStatement.java:1012)

at com.microsoft.sqlserver.jdbc.SQLServerResultSet.checkClosed(SQLServerResultSet.java:428)

at com.microsoft.sqlserver.jdbc.SQLServerResultSet.next(SQLServerResultSet.java:951)

at talend_datamanagement.j_ingestion_full_incr_sqlservercf_to_snowflake_0_1.j_ingestion_full_incr_sqlserverCF_to_snowflake.tDBInput_2Process(j_ingestion_full_incr_sqlserverCF_to_snowflake.java:8892)

at talend_datamanagement.j_ingestion_full_incr_sqlservercf_to_snowflake_0_1.j_ingestion_full_incr_sqlserverCF_to_snowflake.tJava_4Process(j_ingestion_full_incr_sqlserverCF_to_snowflake.java:5715)

at talend_datamanagement.j_ingestion_full_incr_sqlservercf_to_snowflake_0_1.j_ingestion_full_incr_sqlserverCF_to_snowflake.tJava_3Process(j_ingestion_full_incr_sqlserverCF_to_snowflake.java:5280)

at talend_datamanagement.j_ingestion_full_incr_sqlservercf_to_snowflake_0_1.j_ingestion_full_incr_sqlserverCF_to_snowflake.tDBConnection_4Process(j_ingestion_full_incr_sqlserverCF_to_snowflake.java:11434)

at talend_datamanagement.j_ingestion_full_incr_sqlservercf_to_snowflake_0_1.j_ingestion_full_incr_sqlserverCF_to_snowflake.tDBConnection_7Process(j_ingestion_full_incr_sqlserverCF_to_snowflake.java:14158)

at talend_datamanagement.j_ingestion_full_incr_sqlservercf_to_snowflake_0_1.j_ingestion_full_incr_sqlserverCF_to_snowflake.tDBConnection_5Process(j_ingestion_full_incr_sqlserverCF_to_snowflake.java:13814)

at talend_datamanagement.j_ingestion_full_incr_sqlservercf_to_snowflake_0_1.j_ingestion_full_incr_sqlserverCF_to_snowflake.tDBConnection_6Process(j_ingestion_full_incr_sqlserverCF_to_snowflake.java:14502)

at talend_datamanagement.j_ingestion_full_incr_sqlservercf_to_snowflake_0_1.j_ingestion_full_incr_sqlserverCF_to_snowflake.runJobInTOS(j_ingestion_full_incr_sqlserverCF_to_snowflake.java:15529)

at talend_datamanagement.j_ingestion_full_incr_sqlservercf_to_snowflake_0_1.j_ingestion_full_incr_sqlserverCF_to_snowflake.runJob(j_ingestion_full_incr_sqlserverCF_to_snowflake.java:14887)

at talend_datamanagement.j_master_full_incr_sqlservercf_to_snowflake_0_1.j_master_full_incr_sqlserverCF_to_snowflake.tRunJob_3Process(j_master_full_incr_sqlserverCF_to_snowflake.java:6875)

at talend_datamanagement.j_master_full_incr_sqlservercf_to_snowflake_0_1.j_master_full_incr_sqlserverCF_to_snowflake.jblt_getJobAttributes_1_tDBRow_1Process(j_master_full_incr_sqlserverCF_to_snowflake.java:6301)

at talend_datamanagement.j_master_full_incr_sqlservercf_to_snowflake_0_1.j_master_full_incr_sqlserverCF_to_snowflake.jblt_getJobAttributes_1_tDBConnection_2Process(j_master_full_incr_sqlserverCF_to_snowflake.java:4780)

at talend_datamanagement.j_master_full_incr_sqlservercf_to_snowflake_0_1.j_master_full_incr_sqlserverCF_to_snowflake.jblt_get_table_list_for_run_1_tDBInput_2Process(j_master_full_incr_sqlserverCF_to_snowflake.java:4306)

at talend_datamanagement.j_master_full_incr_sqlservercf_to_snowflake_0_1.j_master_full_incr_sqlserverCF_to_snowflake.jblt_get_table_list_for_run_1_tDBInput_1Process(j_master_full_incr_sqlserverCF_to_snowflake.java:3240)

at talend_datamanagement.j_master_full_incr_sqlservercf_to_snowflake_0_1.j_master_full_incr_sqlserverCF_to_snowflake.jblt_get_table_list_for_run_1_tDBConnection_2Process(j_master_full_incr_sqlserverCF_to_snowflake.java:2377)

at talend_datamanagement.j_master_full_incr_sqlservercf_to_snowflake_0_1.j_master_full_incr_sqlserverCF_to_snowflake.jblt_get_table_list_for_run_1_tDBConnection_1Process(j_master_full_incr_sqlserverCF_to_snowflake.java:2100)

at talend_datamanagement.j_master_full_incr_sqlservercf_to_snowflake_0_1.j_master_full_incr_sqlserverCF_to_snowflake.runJobInTOS(j_master_full_incr_sqlserverCF_to_snowflake.java:13851)

at talend_datamanagement.j_master_full_incr_sqlservercf_to_snowflake_0_1.j_master_full_incr_sqlserverCF_to_snowflake.main(j_master_full_incr_sqlserverCF_to_snowflake.java:13236)

Caused by: java.net.SocketException: Connection reset

at java.net.SocketInputStream.read(SocketInputStream.java:210)

at java.net.SocketInputStream.read(SocketInputStream.java:141)

at com.microsoft.sqlserver.jdbc.TDSChannel$ProxyInputStream.readInternal(IOBuffer.java:1003)

at com.microsoft.sqlserver.jdbc.TDSChannel$ProxyInputStream.read(IOBuffer.java:991)

at sun.security.ssl.InputRecord.readFully(InputRecord.java:465)

at sun.security.ssl.InputRecord.read(InputRecord.java:503)

at sun.security.ssl.SSLSocketImpl.readRecord(SSLSocketImpl.java:975)

at sun.security.ssl.SSLSocketImpl.readDataRecord(SSLSocketImpl.java:933)

at sun.security.ssl.AppInputStream.read(AppInputStream.java:105)

at com.microsoft.sqlserver.jdbc.TDSChannel.read(IOBuffer.java:1981)

[Anonymous]

Hello,

Could you please share you job flow? Are you using any tPrejob and tPostJob in your work flow?

Best regards

Sabrina