0

Java ドライバーを使用して Cassandra に接続し、いくつかの構成をフェッチし、結果に基づいていくつかの PIG スクリプトを生成して実行するアプリケーションがあります。

これで、PIG に必要な jar がクラスパスにない場合でも、Cassandra に正常に接続できます。同様に、PigServer クラスを起動し、構成を取得する Java ドライバーを使用して Cassandra に接続していない場合でも、DSE スタック全体を使用してスクリプト/ステートメントを実行できます。

両方を使用すると、次の例外が発生します。

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)

他の人にも同様の例外が見られますが、MapReduce タスクから Cassandra ステートメントを実行しようとすると、これは私の場合ではありません: 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

ありがとう！

4

2 に答える 2

0

DSE スタックは、Cassandra Java ドライバーとは異なる thrift API を介して Cassandra に接続します。

CASSANDRA-6311 が解決されるまで、Pig/Hadoop 用の Cassandra Java ドライバーを使用することはできません。

于 2013-12-03T00:09:29.940 に答える
0

証明書を使用している場合、不適切なセキュリティ証明書/セキュリティ証明書の有効期限の問題が発生する可能性があります。

于 2021-04-26T09:04:10.417 に答える