1

Debian で実行されている Cassandra 1.2.6 に接続する Astyanax 1.56.37:

一見ランダムなポイントで、10.10.1.141 に配置された 1 つのノードのみを含む Cassandra クラスターに対して立て続けに多数の挿入を実行すると、コンソールに次のように表示されます。

- AddHost: 127.0.0.1
- RemoveHost: 10.10.1.141

これを取得した後、このキースペースに接続しようとすると、すべて同じメッセージで失敗します。

これが私の構成です:

AstyanaxContext<Keyspace> context = new AstyanaxContext.Builder()
        .forCluster("Titan Cluster")
        .forKeyspace(keyspaceName)
        .withAstyanaxConfiguration(new AstyanaxConfigurationImpl()
            .setConnectionPoolType(ConnectionPoolType.TOKEN_AWARE)
            .setDiscoveryType(NodeDiscoveryType.RING_DESCRIBE)
            .setTargetCassandraVersion("1.2")
        )
        .withConnectionPoolConfiguration(new ConnectionPoolConfigurationImpl("MyConnectionPool")
            .setPort(9160)
            .setMaxConnsPerHost(50)
            .setSeeds("10.10.1.141:9160")
            .setConnectTimeout(2000)
            .setSocketTimeout(30000)
            .setMaxTimeoutWhenExhausted(10000)
            .setMaxTimeoutCount(3)
            .setTimeoutWindow(10000)
            .setLatencyAwareBadnessThreshold(10)
            .setLatencyAwareUpdateInterval(1000)
            .setLatencyAwareResetInterval(10000)
            .setLatencyAwareWindowSize(100)
        )
        .withConnectionPoolMonitor(new CountingConnectionPoolMonitor())
        .buildKeyspace(ThriftFamilyFactory.getInstance());

    context.start();

での後続の試行で接続が失敗するcontext.start()

4

2 に答える 2