0

私はクレートでベンチマークを行っており、同時に多くのレコードを挿入しています。何らかの制限 (キュー容量 50) に達したようで、構成を変更する方法が見つかりませんでした。

スレッド Thread-1 の例外:

data=data) ファイル "/Users/jodok/sandbox/crate-demo/amsterdam/pyenv/lib/python2.7/site-packages/crate/client/http.py"、345 行目、_json_request self._raise_for_status(response ) ファイル "/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)]; ] in _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)]; ] in _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

しかし、現在のマスターでは、クレートがそのようなキューサイズで現在の一括リクエストを再試行して問題を拒否しているため、これはもう必要ありません。

于 2014-09-12T09:09:13.680 に答える