2

以下のような小さなテスト Java プログラムを使用して、単一の Cassandra 2.0.1 ノードにログインし、エラーなしでクエリを実行できます。

$ java -classpath .:cassandra-driver-core-1.0.4.jar DriverTester 127.0.0.1 myusername mypassword
Got test query result 1ba51260-5b6e-11e3-8f1c-7dd8c1a15c4b

間違ったパスワードを入力すると、予想どおり、「ユーザー名および/またはパスワードが正しくありません」というエラーが表示されて失敗します。

しかし、正しい資格情報を使用して、3 ノード クラスターに属するノードに対して同じプログラムを実行しようとすると、「必要なキー 'ユーザー名' がありません」というメッセージが表示され、やや混乱します。

$ java -classpath .:cassandra-driver-core-1.0.4.jar DriverTester cluster-node1 myusername mypassword
com.datastax.driver.core.exceptions.AuthenticationException: Authentication error on host /62.142.90.104: Required key 'username' is missing
    at com.datastax.driver.core.Connection.initializeTransport(Connection.java:171)
    at com.datastax.driver.core.Connection.<init>(Connection.java:132)
    at com.datastax.driver.core.Connection.<init>(Connection.java:60)
    at com.datastax.driver.core.Connection$Factory.open(Connection.java:419)
    at com.datastax.driver.core.ControlConnection.tryConnect(ControlConnection.java:205)
    at com.datastax.driver.core.ControlConnection.reconnectInternal(ControlConnection.java:168)
    at com.datastax.driver.core.ControlConnection.connect(ControlConnection.java:81)
    at com.datastax.driver.core.Cluster$Manager.init(Cluster.java:773)
    at com.datastax.driver.core.Cluster$Manager.access$100(Cluster.java:706)
    at com.datastax.driver.core.Cluster.<init>(Cluster.java:79)
    at com.datastax.driver.core.Cluster.<init>(Cluster.java:66)
    at com.datastax.driver.core.Cluster$Builder.build(Cluster.java:687)
    at fi.elisa.viihde.stats.DriverTester.openDatastaxSession(DriverTester.java:40)
    at fi.elisa.viihde.stats.DriverTester.doTest(DriverTester.java:28)
    at fi.elisa.viihde.stats.DriverTester.main(DriverTester.java:15)

なぜこうなった？

cqlsh同じ資格情報を指定しても問題なく動作するため、資格情報は正しいです。

$ cqlsh cluster-node1 -u myusername -p mypassword
Connected to cluster-node1 at xx.xx.xx.xx:9160.
[cqlsh 4.0.1 | Cassandra 2.0.1 | CQL spec 3.1.1 | Thrift protocol 19.37.0]
Use HELP for help.
cqlsh>

テスト プログラム コード:

import com.datastax.driver.core.Cluster;
import com.datastax.driver.core.Session;

public class DriverTester {
    public static void main(String... args) {
        try {
            doTest(args);
        } catch (Throwable t) {
            t.printStackTrace();
            System.exit(1);
        }
        System.exit(0);
    }

    public static void doTest(String... args) {
        String[] hostnames = args[0].split(",");
        String username = args[1];
        String password = args[2];

        Cluster.Builder clusterBuilder = Cluster.builder()
                .addContactPoints(hostnames).withPort(9042)
                .withCredentials(username, password);
        Session session = clusterBuilder.build().connect();
        System.out.println("Got test query result " +
                session.execute("select now() from system.local").one().getUUID(0));
    }
}
4

1 に答える 1

2

Cassandra を 2.0.1 から 2.0.3 (または 2.0.2) にアップグレードすると、Datastax ドライバー 2.0.0-rc2 にアップグレードすると、この問題が修正されます。後者については、https ://issues.apache.org/jira/browse/CASSANDRA-6233 を参照してください。

于 2013-12-02T17:03:53.340 に答える