MapReduce ジョブを開始する直前に、 DataStax Java ドライバーを使用して Java コード内の Cassandra にアクセスしています。
cluster = Cluster.builder().addContactPoint("127.0.0.1").build();
ただし、レコードを削減する方法をレコードごとに決定するために、追加情報を確認する必要があります。Hadoop Reducer クラス内で同じコードを使用しようとすると、次のエラーで接続できません。
INFO mapred.JobClient: Task Id :
attempt_201310280851_0012_r_000000_1, Status : FAILED
com.datastax.driver.core.exceptions.NoHostAvailableException:
All host(s) tried for query failed (tried: /127.0.0.1 ([/127.0.0.1]
Unexpected error during transport initialization
(com.datastax.driver.core.TransportException: [/127.0.0.1] Error writing)))
at com.datastax.driver.core.ControlConnection.reconnectInternal(ControlConnection.java:186)
at com.datastax.driver.core.ControlConnection.connect(ControlConnection.java:81)
at com.datastax.driver.core.Cluster$Manager.init(Cluster.java:662)
at com.datastax.driver.core.Cluster$Manager.access$100(Cluster.java:604)
at com.datastax.driver.core.Cluster.<init>(Cluster.java:69)
at com.datastax.driver.core.Cluster.buildFrom(Cluster.java:96)
at com.datastax.driver.core.Cluster$Builder.build(Cluster.java:585)
MapReduce の入力と出力は、Cassandra に対して正常に読み書きされます。前述したように、ジョブを実行する前に接続できるので、Cassandra サーバーの問題ではないと思います。