0

我正在用 crate 做一个基准测试并同时插入很多记录。似乎我达到了一些限制（队列容量 50），但我没有找到如何更改配置。

线程 Thread-1 中的异常：

数据=数据）文件“/Users/jodok/sandbox/crate-demo/amsterdam/pyenv/lib/python2.7/site-packages/crate/client/http.py”，第345行，在_json_request self._raise_for_status（响应) 文件“/Users/jodok/sandbox/crate-demo/amsterdam/pyenv/lib/python2.7/site-packages/crate/client/http.py”，第 331 行，在 _raise_for_status raise ProgrammingError(error.get(' message', '')) ProgrammingError: SQLActionException[RemoteTransportException[[nuc2][inet[/192.168.42.72:4300]][bulk/shard]]; 嵌套：EsRejectedExecutionException[在 org.elasticsearch.action.support.replication.TransportShardReplicationOperationAction$AsyncShardOperationAction$1@23c7247f 上拒绝执行（队列容量 50）]；] 在 _raise_for_status raise ProgrammingError(error.get('message', '')) ProgrammingError: SQLActionException[RemoteTransportException[[nuc2][inet[/192.168.42.72:4300]][bulk/shard]]; 嵌套：EsRejectedExecutionException[在 org.elasticsearch.action.support.replication.TransportShardReplicationOperationAction$AsyncShardOperationAction$1@23c7247f 上拒绝执行（队列容量 50）]；] 在 _raise_for_status raise ProgrammingError(error.get('message', '')) ProgrammingError: SQLActionException[RemoteTransportException[[nuc2][inet[/192.168.42.72:4300]][bulk/shard]]; 嵌套：EsRejectedExecutionException[在 org.elasticsearch.action.support.replication.TransportShardReplicationOperationAction$AsyncShardOperationAction$1@23c7247f 上拒绝执行（队列容量 50）]；]

4

1 回答 1

0

批量插入正在使用批量线程池，因此将其添加到您的 crate.yml 配置文件以更改其大小：

threadpool.bulk.queue_size: 100

但是对于当前的 master，这应该不再需要了，因为 crate 现在正在重试当前的批量请求，以解决这样的队列大小拒绝问题。

于 2014-09-12T09:09:13.680 回答