Sqoop2:在connectorForm中设置table.sql (使用免费查询)在createJob()上返回“不可接受的”状态

Question

我指的是编写我的Sqoop2客户端程序的指南：http://sqoop.apache.org/docs/1.99.2/ClientAPI.html

该示例只显示在table.columns属性中设置列名，它可以正常工作，但会导入表中的所有记录。我只需要导入一组基于简单WHER-子句sql的记录。我尝试设置table.sql属性，但是它在调用SqoopClient.createJob(newJob)时总是返回“不可接受的”状态。有人使用Sqoop2 (CDH4.4.0)中的免费表单查询成功地运行了导入吗？

connectorForm.getStringInput("table.sql").setValue("select id,value from tableName where ${CONDITIONS} and groupid=123");

Answer 1

除了SqoopClient.createJob()返回的总体状态外，给定的MJob对象还将使用状态消息进行更改。通过迭代表单和输入并调用方法getValidationMessage()，您可以获得准确的错误消息，说明您的作业有什么问题。