我编写了一个Sqoop导入程序,使用where子句从Netezza导入数据,当where子句中存在语法错误时,Sqoop生成的映射器会抛出Netezza级语法错误并挂起。如何捕获这些方案并使我的Sqoop导入作业失败。
已将驱动程序选项--driver org.netezza.Driver添加到sqoop import命令,如果生成的查询中存在任何语法错误,则会导致sqoop导入失败。由于我们指定了驱动程序,因此sqoop import使用jdbc而不是带有direct选项的外部表。