Talend Open Studio giving me I/O Error: Connection reset by peer

[Anonymous]

Hi
I just got "I/O Error: Connection reset by peer: socket write error" when running an overnight job. I researched the problem on the internet and it seems its probably caused by many concurrent users on MS SQL Server confusing Java that socked was closed. Did anything similar happened to anyone in the community?
OS: Win7; DB: Microsoft SQL Server 2008.
Error message:
connecting to socket on port 4030
connected
I/O Error: Connection reset by peer: socket write error
Exception in component tMSSqlOutput_2
java.sql.SQLException: Invalid state, the Connection object is closed.
at net.sourceforge.jtds.jdbc.TdsCore.checkOpen(TdsCore.java:448)
at net.sourceforge.jtds.jdbc.TdsCore.clearResponseQueue(TdsCore.java:723)
at net.sourceforge.jtds.jdbc.JtdsStatement.initialize(JtdsStatement.java:586)
at net.sourceforge.jtds.jdbc.JtdsStatement.executeBatch(JtdsStatement.java:851)
at undq.test_fuzzy_trigram_without_joins_0_1.TEST_fuzzy_trigram_without_joins.tMSSqlInput_3Process(TEST_fuzzy_trigram_without_joins.java:3741)
at undq.test_fuzzy_trigram_without_joins_0_1.TEST_fuzzy_trigram_without_joins.runJobInTOS(TEST_fuzzy_trigram_without_joins.java:5298)
at undq.test_fuzzy_trigram_without_joins_0_1.TEST_fuzzy_trigram_without_joins.main(TEST_fuzzy_trigram_without_joins.java:5172)
disconnected
Job TEST_fuzzy_trigram_without_joins ended at 20:50 30/06/2010.

[Anonymous]

Hi,

Any solution for this. I am also struggling to fix this issue.

Thanks

[Anonymous]

Hello @tariq4you，

Could you please indicate on which talend build version you got this issue? What's your DB source? Any information will be preferred.

Best regards

Sabrina

[Anonymous]

Hi, 

Thanks for your response. I am using Talend 7.1.1.  My source is Salesforce and my target is Microsoft SQL Server which is hosted on Azure cloud. Whenever i execute the job it fails in 90% case and pass only 10%. I already tried with reducing batch size but no permanent solution.  It  always gives error that

I/O error : connection is reset by peer : socket write error

OR

Exception in component tDBOutput_1

Java.sqlbatchupdateexception I/O error : Connection reset

Any help is greatly appreciated. 

Thanks in advance. 

[Anonymous]

Hello,

Is it the same result when you use tDBConnection component in your job? Are you using one database connection, that is subsequently used by multiple threads? Your Job design screenshots will be helpful for us to address your issue.

Best regards

Sabrina

[Anonymous]

Hi, 

Looks like issue was with selected db version while creating the connection. Earlier it was Open Source JTDS then i changed to Microsoft and it worked for me. Hope it will help some other folks. 

Thanks for your help. 

[Anonymous]

hi, 

any explanation of the solution? i have similar error. i built my talend job  Version: 7.1.1 Both the bat and powershell script are getting the error below. the job step is connecting to Oracle 12c version 12.1.0.2.0.

java : Exception in component tDBSP_5 (Load_new_client_family_DEV)
At C:\TALEND\Load_CRN_DEV_0.1\Load_new_client_family_DEV\Load_new_client_family_DEV_run.ps1:3 char:1
+ java '-Dtalend.component.manager.m2.repository=%cd%/../lib' '-Xms256M ...
+ ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
+ CategoryInfo : NotSpecified: (Exception in co...ent_family_DEV)tring) [], RemoteException
+ FullyQualifiedErrorId : NativeCommandError

java.sql.SQLRecoverableException: IO Error: Connection reset
at oracle.jdbc.driver.T4CCallableStatement.executeForRows(T4CCallableStatement.java:962)
at oracle.jdbc.driver.OracleStatement.doExecuteWithTimeout(OracleStatement.java:1075)
at oracle.jdbc.driver.OraclePreparedStatement.executeInternal(OraclePreparedStatement.java:3820)
at oracle.jdbc.driver.OraclePreparedStatement.execute(OraclePreparedStatement.java:3923)
at oracle.jdbc.driver.OracleCallableStatement.execute(OracleCallableStatement.java:5617)
at oracle.jdbc.driver.OraclePreparedStatementWrapper.execute(OraclePreparedStatementWrapper.java:1385)
at daily_refresh.load_new_client_family_dev_0_1.Load_new_client_family_DEV.tFixedFlowInput_4Process(Load_new_client_family_DEV.java:1398)
at daily_refresh.load_new_client_family_dev_0_1.Load_new_client_family_DEV.runJobInTOS(Load_new_client_family_DEV.java:12167)
at daily_refresh.load_new_client_family_dev_0_1.Load_new_client_family_DEV.main(Load_new_client_family_DEV.java:11891)
Caused by: java.net.SocketException: Connection reset
at java.net.SocketInputStream.read(Unknown Source)
at java.net.SocketInputStream.read(Unknown Source)
at oracle.net.ns.Packet.receive(Packet.java:311)
at oracle.net.ns.DataPacket.receive(DataPacket.java:105)
at oracle.net.ns.NetInputStream.getNextPacket(NetInputStream.java:305)
at oracle.net.ns.NetInputStream.read(NetInputStream.java:249)
at oracle.net.ns.NetInputStream.read(NetInputStream.java:171)
at oracle.net.ns.NetInputStream.read(NetInputStream.java:89)
at oracle.jdbc.driver.T4CSocketInputStreamWrapper.readNextPacket(T4CSocketInputStreamWrapper.java:123)
at oracle.jdbc.driver.T4CSocketInputStreamWrapper.read(T4CSocketInputStreamWrapper.java:79)
at oracle.jdbc.driver.T4CMAREngineStream.unmarshalUB1(T4CMAREngineStream.java:426)
at oracle.jdbc.driver.T4CTTIfun.receive(T4CTTIfun.java:390)
at oracle.jdbc.driver.T4CTTIfun.doRPC(T4CTTIfun.java:249)
at oracle.jdbc.driver.T4C8Oall.doOALL(T4C8Oall.java:566)
at oracle.jdbc.driver.T4CCallableStatement.doOall8(T4CCallableStatement.java:210)
at oracle.jdbc.driver.T4CCallableStatement.doOall8(T4CCallableStatement.java:53)
at oracle.jdbc.driver.T4CCallableStatement.executeForRows(T4CCallableStatement.java:938)
... 8 more

[Pooja_kataria]

Hey how did you changed the db version to Microsoft .I am facing same kind of error.

Your help will be appreciated