Ошибка при попытке импортировать данные из MySQL в Кассандру с помощью sqoop

Я установил DSE и установил путь в.bashrc и sqoop-env.sh. Во-первых, я запустил DSE с помощью команды

cd dse/bin

sudo sh dse-env.sh

затем я запустил процесс отслеживания заданий и задач с помощью команды

~/dse/bin/dse Cassandra -t

Я попытался импортировать базу данных person.empl, в уже созданное семейство пустых столбцов emp из пространства ключей comp, используя команду

~/dse/bin/dse sqoop cql-import --table empl --cassandra-keyspace comp --cassandra-table emp --connect jdbc:mysql://127.0.0.1/person --username root --password root --cassandra-host 127.0.0.1 -m 1

но я получаю следующее исключение

Exception in thread "main" java.lang.NoSuchMethodError: org.jboss.netty.handler.codec.frame.LengthFieldBasedFrameDecoder.<init>(IIIIIZ)V
    at com.datastax.driver.core.Frame$DecoderV1.<init>(Frame.java:179)
    at com.datastax.driver.core.Frame$Decoder.<clinit>(Frame.java:162)
    at com.datastax.driver.core.Connection$PipelineFactory.getPipeline(Connection.java:1029)
    at org.jboss.netty.bootstrap.ClientBootstrap.connect(ClientBootstrap.java:212)
    at org.jboss.netty.bootstrap.ClientBootstrap.connect(ClientBootstrap.java:188)
    at com.datastax.driver.core.Connection.<init>(Connection.java:99)
    at com.datastax.driver.core.Connection$Factory.open(Connection.java:573)
    at com.datastax.driver.core.ControlConnection.tryConnect(ControlConnection.java:244)
    at com.datastax.driver.core.ControlConnection.reconnectInternal(ControlConnection.java:190)
    at com.datastax.driver.core.ControlConnection.connect(ControlConnection.java:78)
    at com.datastax.driver.core.Cluster$Manager.init(Cluster.java:1230)
    at com.datastax.driver.core.Cluster.init(Cluster.java:157)
    at com.datastax.driver.core.Cluster.connect(Cluster.java:245)
    at com.datastax.bdp.sqoop.SqoopUtil.setCqlImportOptions(SqoopUtil.java:146)
    at com.datastax.bdp.sqoop.CqlImportJob.configureOutputFormat(CqlImportJob.java:79)
    at org.apache.sqoop.mapreduce.ImportJobBase.runImport(ImportJobBase.java:240)
    at com.datastax.bdp.sqoop.SqlManagerAdapter.importTable(SqlManagerAdapter.java:236)
    at org.apache.sqoop.tool.ImportTool.importTable(ImportTool.java:497)
    at org.apache.sqoop.tool.ImportTool.run(ImportTool.java:601)
    at org.apache.sqoop.Sqoop.run(Sqoop.java:143)
    at org.apache.hadoop.util.ToolRunner.run(ToolRunner.java:65)
    at org.apache.sqoop.Sqoop.runSqoop(Sqoop.java:179)
    at org.apache.sqoop.Sqoop.runTool(Sqoop.java:218)
    at org.apache.sqoop.Sqoop.runTool(Sqoop.java:227)
    at org.apache.sqoop.Sqoop.main(Sqoop.java:236)
    at com.cloudera.sqoop.Sqoop.main(Sqoop.java:57)

Версия nettyjar, представленная в Cassandra/lib, - 4.0.23, а в Cassandra/tools/lib - 3.9.0.

Может кто-нибудь помочь решить эту проблему?

0 ответов

Другие вопросы по тегам