Блог

Я написал программу импорта Sqoop для импорта данных из Netezza с использованием предложения where, когда в предложении where возникает синтаксическая ошибка, mappers, сгенерированные Sqoop, выдают синтаксическую ошибку уровня Netezza и зависают. Как мне зафиксировать эти сценарии и выполнить сбой задания импорта Sqoop.

Добавлена опция драйвера -driver org.netezza.Драйвер для команды импорта sqoop и сбой импорта sqoop при наличии каких-либо синтаксических ошибок в сгенерированном запросе. Поскольку мы указываем драйвер, при импорте sqoop используется jdbc, а не внешняя таблица с прямой опцией.