2016-11-07 4 views
0

なしスニッフィング接続プールが動作しているようです。SniffingConnectionPoolを使用しているときのネスト2.4.6エラー

var settings2 = new ConnectionSettings(new Uri(elasticSearchUri)) 
_elasticClient = new ElasticClient(settings2); 

しかし、下のConnectionSettingsにSniffingConnectionPoolを使用:以下のエラーで

var settings2 = new ConnectionSettings(new SniffingConnectionPool(new[] { new Uri(elasticSearchUri) })) 
       .DefaultIndex("myindex") 
       .DisableDirectStreaming(true); 

結果: は、 "クラスタの状態を盗聴できませんでした。"

Splunkのログ

Unable to import data to ElasticSearch - Failed sniffing cluster state.    PipelineException Project.ScheduledJobService LOCAL ERROR 
Unable to import data to ElasticSearch - One or more errors occurred.    AggregateException Project.ScheduledJobService LOCAL ERROR 
Unable to import data to ElasticSearch - Object reference not set to an instance of an object. 
NullReferenceException Project.ScheduledJobService 

全トレース:

at Elasticsearch.Net.RequestPipeline.Sniff() in C:\Users\russ\source\elasticsearch-net-2.x\src\Elasticsearch.Net\Transport\Pipeline\RequestPipeline.cs:line 358 
    at Elasticsearch.Net.RequestPipeline.FirstPoolUsage(SemaphoreSlim semaphore) in C:\Users\russ\source\elasticsearch-net-2.x\src\Elasticsearch.Net\Transport\Pipeline\RequestPipeline.cs:line 143 
    at Elasticsearch.Net.Transport`1.Request[TReturn](HttpMethod method, String path, PostData`1 data, IRequestParameters requestParameters) in C:\Users\russ\source\elasticsearch-net-2.x\src\Elasticsearch.Net\Transport\Transport.cs:line 53 
    at Elasticsearch.Net.ElasticLowLevelClient.DoRequest[T](HttpMethod method, String path, PostData`1 data, IRequestParameters requestParameters) in C:\Users\russ\source\elasticsearch-net-2.x\src\Elasticsearch.Net\ElasticLowLevelClient.cs:line 58 
    at Elasticsearch.Net.ElasticLowLevelClient.Bulk[T](PostData`1 body, Func`2 requestParameters) in C:\Users\russ\source\elasticsearch-net-2.x\src\Elasticsearch.Net\ElasticLowLevelClient.Generated.cs:line 32 
    at Nest.LowLevelDispatch.BulkDispatch[T](IRequest`1 p, PostData`1 body) in C:\Users\russ\source\elasticsearch-net-2.x\src\Nest\_Generated\_LowLevelDispatch.generated.cs:line 26 
    at Nest.ElasticClient.Nest.IHighLevelToLowLevelDispatcher.Dispatch[TRequest,TQueryString,TResponse](TRequest request, Func`3 responseGenerator, Func`3 dispatch) in C:\Users\russ\source\elasticsearch-net-2.x\src\Nest\ElasticClient.cs:line 56 
    at Nest.ElasticClient.Nest.IHighLevelToLowLevelDispatcher.Dispatch[TRequest,TQueryString,TResponse](TRequest request, Func`3 dispatch) in C:\Users\russ\source\elasticsearch-net-2.x\src\Nest\ElasticClient.cs:line 46 
    at Nest.ElasticClient.Bulk(IBulkRequest request) in C:\Users\russ\source\elasticsearch-net-2.x\src\Nest\Document\Multiple\Bulk\ElasticClient-Bulk.cs:line 32 
    at Project.Core.Services.ElasticSearchService.IndexMultiple(IEnumerable`1 documents) 
    at Project.ScheduledJobService.Jobs.ElasticSearch.ElasticSearchTrackedChangesDataImportJob.Execute() in C:\Users\Martynas.Valaika\Code\Project\Main\Source\Project\Project.ScheduledJobService\Jobs\Elasticsearch\ElasticSearchTrackedChangesDataImportJob.cs:line 35 

答えて

1

はどうやらES 5.0のバグがあります。 SniffingConnectionPoolをSingleNodeConnectionPoolに置き換えると、そのジョブが実行されます。

var pool = new SingleNodeConnectionPool(new Uri(uri)); 
       var settings = new ConnectionSettings(pool, connectionSettings => new MyJsonNetSerializer(connectionSettings)) 
        .DefaultIndex("seetickets_search_results") 
        .DisableDirectStreaming(); 

       _elasticClient = new ElasticClient(settings); 
+2

バグへのリンクがありますか? 'SingleNodeConnectionPool'と' SniffingConnectionPool'は、要求を送ることができるノードを維持することに関して、異なることを行います。 NEST 2.4.7はElasticsearch 5.0と互換性がありません。5.0に対して実行している場合は、NEST 5.0.0-rc1を使用してください。 –

関連する問題