我引用此指南来编写我的Sqoop2客户端程序:
http://sqoop.apache.org/docs/1.99.2/ClientAPI.html
该示例显示仅在table.columns属性中设置列名，它可以正常工作，但可以导入表中的所有记录。我只需要根据一个简单的where-clause sql导入一组记录。我尝试设置table.sql属性，但在调用SqoopClient.createJob(newJob)时始终返回“ Not Acceptable ”状态。是否有人在Sqoop2(CDH4.4.0)中使用自由格式查询成功运行了导入？
connectorForm.getStringInput("table.sql").setValue("select id,value from tableName where ${CONDITIONS} and groupid=123");
最佳答案
除了SqoopClient.createJob()返回的总体状态之外，给定的MJob对象还将通过状态消息进行更改。通过遍历表单和输入并调用方法getValidationMessage()，可以获得有关您的工作出了什么问题的精确错误消息。
关于hadoop - Sqoop2:在connectorForm中设置table.sql(免费使用查询)在createJob()上返回 'unacceptable'状态，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/19837586/