2017-06-19 89 views
0

我一直試圖將行添加到cassandra表中一段時間​​,但幾秒鐘後不斷髮送給我相同的錯誤消息:池是忙(沒有可用的連接後10000毫秒超時))Cassandra:池正忙(沒有可用的連接,超過10000個MILLISECONDS後超時))

我仍然有插入(百)了幾行,但它很快將停止

我試着改變一些poolingoptions但沒」 T改變了:

PoolingOptions poolingOptions = new PoolingOptions();// 
     poolingOptions.setMaxRequestsPerConnection(HostDistance.LOCAL, 32768); 
     poolingOptions.setPoolTimeoutMillis(10000); 
     poolingOptions.setMaxConnectionsPerHost(HostDistance.LOCAL, 8); 
     poolingOptions.setMaxQueueSize(20); 
     poolingOptions.setIdleTimeoutSeconds(20); 

想知道我能做什麼嗎?

感謝您的幫助!

+0

你的cassandra集羣的負載是什麼? – maasg

+0

我的cassandra集羣的負載是7.6 Go – Jean

+0

我的意思是「負載」方面的CPU負載。看起來羣集太忙而無法接受新的連接。 – maasg

回答

0

您需要設置核心連接到最大。

val poolingOptions = new PoolingOptions() 
    .setConnectionsPerHost(HostDistance.LOCAL, 1, 2) 
    .setMaxRequestsPerConnection(HostDistance.LOCAL, 32768) 
    .setCoreConnectionsPerHost(HostDistance.LOCAL, 2) 

您可以根據您的要求設置配置。就像,最大的請求可以達到多少。目前的配置可以管理大約5萬個請求。 欲瞭解更多信息refer

相關問題