BTW, We are going to enhance the HCatalog integration on Sqoop1 to support all the Hive 0.13 datatypes. Just cleaing up the code and adding tests. Will be posting for review. Will try to do a parquet test also.
Venkat On Tue, Jun 17, 2014 at 5:55 PM, Benyi Wang <[EMAIL PROTECTED]> wrote:
CONFIDENTIALITY NOTICE NOTICE: This message is intended for the use of the individual or entity to which it is addressed and may contain information that is confidential, privileged and exempt from disclosure under applicable law. If the reader of this message is not the intended recipient, you are hereby notified that any printing, copying, dissemination, distribution, disclosure or forwarding of this communication is strictly prohibited. If you have received this communication in error, please contact the sender immediately and delete it from your system. Thank You.
The problems are: 1. the job finished successfully, but the file in /tmp/action_t/_TEMP is in text format. 2. If I use "--hcatalog-table action_text --create-hcatalog-table", the data is not loaded into Hive.
Did I miss something? On Tue, Jun 17, 2014 at 5:57 PM, Venkat Ranganathan < [EMAIL PROTECTED]> wrote:
"Cloudera connector Powered by Teradata" seems not to support HCatalog.
If using GenericJdbcManager, I could create hcatalog table using ORC, but failed with this error to write into a parquet table:
2014-06-18 17:11:38,881 WARN [main] org.apache.hadoop.mapred.YarnChild: Exception running child : java.lang.RuntimeException: Should never be used at org.apache.hadoop.hive.ql.io.parquet.MapredParquetOutputFormat.getRecordWriter(MapredParquetOutputFormat.java:76) at org.apache.hcatalog.mapreduce.FileOutputFormatContainer.getRecordWriter(FileOutputFormatContainer.java:109) at org.apache.hcatalog.mapreduce.HCatOutputFormat.getRecordWriter(HCatOutputFormat.java:245) at org.apache.hadoop.mapred.MapTask$NewDirectOutputCollector.<init>(MapTask.java:624) at org.apache.hadoop.mapred.MapTask.runNewMapper(MapTask.java:744) at org.apache.hadoop.mapred.MapTask.run(MapTask.java:340) at org.apache.hadoop.mapred.YarnChild$2.run(YarnChild.java:168) 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:1548) at org.apache.hadoop.mapred.YarnChild.main(YarnChild.java:163)
Apache Lucene, Apache Solr and all other Apache Software Foundation project and their respective logos are trademarks of the Apache Software Foundation.
Elasticsearch, Kibana, Logstash, and Beats are trademarks of Elasticsearch BV, registered in the U.S. and in other countries. This site and Sematext Group is in no way affiliated with Elasticsearch BV.
Service operated by Sematext