Ошибка при попытке импортировать данные из 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.
Может кто-нибудь помочь решить эту проблему?