org.jboss.netty.channel.ChannelPipelineException: не удалось инициализировать конвейер

У меня есть приложение, которое подключается к Cassandra с помощью драйвера Java, извлекает некоторую конфигурацию и на основе результатов генерирует и выполняет некоторые сценарии PIG.

Теперь я могу успешно подключиться к Cassandra, когда jar-файлы, необходимые для PIG, отсутствуют в пути к классам. Точно так же я могу запускать класс PigServer и выполнять сценарии/операторы, используя весь стек DSE, когда я не подключаюсь к Cassandra с помощью драйвера java для получения конфигурации.

Когда я использую их оба, я получаю следующее исключение:

org.jboss.netty.channel.ChannelPipelineException: Failed to initialize a pipeline.
        at org.springframework.beans.factory.support.SimpleInstantiationStrategy.instantiate(SimpleInstantiationStrategy.java:181)
        at org.springframework.beans.factory.support.ConstructorResolver.instantiateUsingFactoryMethod(ConstructorResolver.java:570)
        ... 35 more
Caused by: org.jboss.netty.channel.ChannelPipelineException: Failed to initialize a pipeline.
        at org.jboss.netty.bootstrap.ClientBootstrap.connect(ClientBootstrap.java:208)
        at org.jboss.netty.bootstrap.ClientBootstrap.connect(ClientBootstrap.java:182)
        at com.datastax.driver.core.Connection.<init>(Connection.java:100)
        at com.datastax.driver.core.Connection.<init>(Connection.java:51)
        at com.datastax.driver.core.Connection$Factory.open(Connection.java:376)
        at com.datastax.driver.core.ControlConnection.tryConnect(ControlConnection.java:207)
        at com.datastax.driver.core.ControlConnection.reconnectInternal(ControlConnection.java:170)
        at com.datastax.driver.core.ControlConnection.connect(ControlConnection.java:87)
        at com.datastax.driver.core.Cluster$Manager.init(Cluster.java:576)
        at com.datastax.driver.core.Cluster$Manager.access$100(Cluster.java:520)
        at com.datastax.driver.core.Cluster.<init>(Cluster.java:67)
        at com.datastax.driver.core.Cluster.buildFrom(Cluster.java:94)
        at com.datastax.driver.core.Cluster$Builder.build(Cluster.java:501)

Я вижу, что другие видели подобное исключение, но при попытке выполнить операторы Cassandra из задач MapReduce, что не в моем случае: https://groups.google.com/a/lists.datastax.com/forum/#!topic/java-driver-user/FhW_8e4FyAI http://www.datastax.com/dev/blog/the-native-cql-java-driver-goes-ga#comment-297187

Спасибо!


datastax-java-driver datastax-enterprise
person Dumitru P.    schedule 01.12.2013    source источник

Ответы (2)


arrow_upward
0
arrow_downward

Стеки DSE подключаются к Cassandra через экономичный API, который отличается от Java-драйвера Cassandra.

Вы не можете использовать драйвер Cassandra Java для Pig/Hadoop, пока CASSANDRA-6311 не будет устранена.

person alexLiu    schedule 03.12.2013
comment
Я не использую драйвер Cassandra Java в Pig/Hadoop Map Reduce Job. Я использую его только перед запуском задания Hadoop. Правильно ли я говорю, что бережливость и драйвер Java нельзя использовать в одной и той же JVM? - person Dumitru P.; 04.12.2013
comment
Путь к классам куста DSE имеет разные версии netty lib, чем cassandra, вам может потребоваться удалить его, когда вы добавляете путь к классам DSE в свое приложение. - person alexLiu; 05.12.2013

arrow_upward
0
arrow_downward

Если вы используете сертификат, может возникнуть проблема с неверным сертификатом безопасности/истечением срока действия сертификата безопасности.

person Abhale Amol    schedule 26.04.2021