Has anyone seen an intermittent error while exporting from HDP to external DB via Teradata Connector:
2015-09-22 13:03:29,969 WARN [main] org.apache.hadoop.mapred.YarnChild: Exception running child : com.teradata.connector.common.exception.ConnectorException: java.net.ConnectException: Connection refused
at java.net.PlainSocketImpl.socketConnect(Native Method)
at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:339)
at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:200)
at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:182)
at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
at java.net.Socket.connect(Socket.java:579)
at java.net.Socket.connect(Socket.java:528)
at java.net.Socket.<init>(Socket.java:425)
at java.net.Socket.<init>(Socket.java:208)
at com.teradata.connector.teradata.TeradataInternalFastloadOutputFormat.getRecordWriter(TeradataInternalFastloadOutputFormat.java:301)
at com.teradata.connector.common.ConnectorOutputFormat$ConnectorFileRecordWriter.<init>(ConnectorOutputFormat.java:84)
at com.teradata.connector.common.ConnectorOutputFormat.getRecordWriter(ConnectorOutputFormat.java:33)
at org.apache.hadoop.mapred.MapTask$NewDirectOutputCollector.<init>(MapTask.java:644)
at org.apache.hadoop.mapred.MapTask.runNewMapper(MapTask.java:764)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:341)
at org.apache.hadoop.mapred.YarnChild$2.run(YarnChild.java:163)
at java.security.AccessController.doPrivileged(Native Method)
at javax.security.auth.Subject.doAs(Subject.java:415)
at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1628)
at org.apache.hadoop.mapred.YarnChild.main(YarnChild.java:158)
The connection string is:
hadoop jar /usr/hdp/2.2.4.5-1/sqoop/lib/teradata-connector-1.3.5-hadoop220.jar com.teradata.hadoop.tool.TeradataExportTool -url jdbc:teradata://<server>/Database=PR_ODMM_STG -username PR_BATCH_ODMM_SQL -password xxxxx -errortabledatabase PR_ODMM_STG -jobtype hdfs -sourcepaths /user/hive/warehouse/edw_odmm_stg.db/omn_aggregates/batch_id=15/agg_tab_partition=STG_INTERNAL_SEARCH_KEYWORD_1 -nummappers 5 -separator \u001E -targettable STG_INTERNAL_SEARCH_KEYWORD_1 -errortablename NTERNAL_SEARCH_KEYWORD_1 -method internal.fastload &
