【发布时间】:2023-04-05 07:24:01
【问题描述】:
我编写了一个 Sqoop 导入程序,使用 where 子句从 Netezza 导入数据,当 where 子句出现语法错误时,Sqoop 生成的映射器会抛出 Netezza 级别的语法错误并挂起。 如何捕捉这些场景并让我的 Sqoop 导入作业失败。
【问题讨论】:
我编写了一个 Sqoop 导入程序,使用 where 子句从 Netezza 导入数据,当 where 子句出现语法错误时,Sqoop 生成的映射器会抛出 Netezza 级别的语法错误并挂起。 如何捕捉这些场景并让我的 Sqoop 导入作业失败。
【问题讨论】:
已在 sqoop 导入命令中添加了驱动程序选项 --driver org.netezza.Driver,如果生成的查询中有任何语法错误,它会导致 sqoop 导入失败。 由于我们指定了驱动,所以 sqoop 导入使用的是 jdbc 而不是带有直接选项的外部表。
【讨论】: