我编写了一个sqoop导入程序,使用where子句从netezza导入数据,当where子句出现语法错误时,sqoop生成的Map器抛出netezza级语法错误并挂起。如何捕获这些场景并使sqoop导入作业失败。
z9zf31ra1#
在sqoop import命令中添加了driver option--driver org.netezza.driver,如果生成的查询中有语法错误,它将导致sqoop导入失败。因为我们指定的是驱动程序,所以sqoop import使用的是jdbc,而不是带有direct选项的外部表。
1条答案
按热度按时间z9zf31ra1#
在sqoop import命令中添加了driver option--driver org.netezza.driver,如果生成的查询中有语法错误,它将导致sqoop导入失败。因为我们指定的是驱动程序,所以sqoop import使用的是jdbc,而不是带有direct选项的外部表。