Broken Pipe error at tHive components

[ngpr2020]

Hi,

I'm facing the following errors while running a Talend job, at tHiveInput & tHiveRow components:

tHiveInput_1 Invalid OperationHandle: OperationHandle [opType=EXECUTE_STATEMENT, getHandleIdentifier()=8363b5ee-6284-4ad5-9595-3a6dfc52a051]org.apache.hive.service.cli.HiveSQLException: Invalid OperationHandle: OperationHandle [opType=EXECUTE_STATEMENT, getHandleIdentifier()=8363b5ee-6284-4ad5-9595-3a6dfc52a051]

       at org.apache.hive.jdbc.Utils.verifySuccess(Utils.java:241)

       at org.apache.hive.jdbc.Utils.verifySuccessWithInfo(Utils.java:227)

       at org.apache.hive.jdbc.HiveStatement.closeClientOperation(HiveStatement.java:189)

       at org.apache.hive.jdbc.HiveStatement.close(HiveStatement.java:211)

I have tried using various other components but it still fails:

tImpalaRow_1 org.apache.thrift.transport.TTransportException: java.net.SocketException: Broken pipe (Write failed)

java.sql.SQLException: org.apache.thrift.transport.TTransportException: java.net.SocketException: Broken pipe (Write failed) at org.apache.hive.jdbc.HiveStatement.execute(HiveStatement.java:255)

The component is performing an Insert overwrite on a staging table, while partitioning over year and month.

If anyone has any idea regarding the error or how to resolve it.

Any input is greatly appreciated.

Thanks.

[Anonymous]

Hello,

During a write the connection was severed, this can be due the the destination closing the connection or the destination process has terminated. What's hive version are you trying to set up and your JDK version?

Best regards

Sabrina