在编写我的sqoop2客户机程序时，我参考了以下指南：http://sqoop.apache.org/docs/1.99.2/clientapi.html
该示例显示只需在table.columns属性中设置列名，就可以正常工作，但会导入表中的所有记录。我只需要导入一组基于简单where子句sql的记录。我尝试设置table.sql属性，但在调用sqoopclient.createjob（newjob）时，它总是返回“unacceptable”状态。有人在sqoop2（cdh4.4.0）中使用自由形式查询成功运行import吗？
connectorForm.getStringInput("table.sql").setValue("select id,value from tableName where ${CONDITIONS} and groupid=123");
1条答案
按热度按时间toiithl61#
除了sqoopclient.createjob（）返回的整体状态之外，给定的mjob对象还将使用状态消息进行更改。通过对表单和输入进行迭代并调用getvalidationmessage（）方法，可以获得有关作业错误的准确错误消息。