Sqoop не может импортировать данные из MYSQL в HBASE

Question

Привет, я новичок в bigdata и пытаюсь импортировать данные из mysql в hbase, используя sqoop.

sqoop import –connect jdbc:mysql://xxx.xxx.xx.xx:3306/FBI_DB –table FBI_CRIME –hbase-table H_FBI_CRIME –column-family cd –hbase-row-key ID –m 1 –username root -P

ОШИБКА tool.ImportTool: Ошибка импорта: java.io.IOException: Нет столбцов для ClassWriter.

Как только я использовал ––driver com.mysql.jdbc.Driver, но все еще не добился успеха.

Пожалуйста, помогите, что не так.

Answer 1

Проблема в том, что вам нужно указать имена столбцов, которые вы хотите импортировать, например:

sqoop import --connect jdbc:mysql://xxx.xxx.xx.xx:3306/FBI_DB \
--table FBI_CRIME \
--hbase-table H_FBI_CRIME \
--columns "columnA,columnB" \
--column-family cd \
--hbase-row-key ID \
-m 1 \
--username root -P