我正在使用cassandra 3.x和节点10.13.0。我的工作内存中有100,000个用户的数据(在给定代码中的地图’sortedRowMap’中)。我正在通过迭代地图来更新所有记录(有…
您需要增加每个连接的正在进行的请求数。协议版本3+支持最多32k的飞行请求。你需要添加相应的选项( maxRequestsPerConnection 进入 pooling 对象,比如,这个:
pooling
pooling: { coreConnectionsPerHost: { [distance.local] : 2, [distance.remote] : 1 }, maxRequestsPerConnection: 32768 }
但是,如果所有请求都命中相同的节点,您仍然可以遇到此异常。在这种情况下,您需要限制提交,或重新尝试
另见相应的 “DataStax开发指南”中的部分 。