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()