Elasticsearch: Bizim projede <strong>Elasticsearch Plugin</strong> kullanıyoruz AssertionError takma

Question

gelen endeks adını alırken. hata

Hata

{ 
    "error": "AssertionError[Expected current thread[Thread[elasticsearch[Seth][http_server_worker][T#2]{New I/O worker #20},5,main]] to not be a transport thread. Reason: [Blocking operation]]", "status": 500 
    } 

Kod bu sorunu neyin sebep

String realIndex = client.admin().cluster().prepareState() 
        .execute().actionGet().getState().getMetaData() 
        .aliases().get(aliasName).iterator() 
        .next().key; 

altına alma takma den endeks adı elde ederken ?? Bu işlem geri sonuç elde edene kadar bu iş parçacığı engeller olarak taşıma parçacığı üzerinde izin verilmez gibi hata bakacak olursak herhangi bir yardım

Answer 1

alamadım googledaarattın, öyle görünüyor. Bunu bir yürütme iş parçacığında yürütmeniz gerekir.

public String getIndexName() { 
    final IndexNameHolder result = new IndexNameHolder(); // holds the index Name. Needed a final instance here, hence created a holder. 
    getTransportClient().admin().cluster().prepareState().execute(new ActionListener<ClusterStateResponse>() { 

     @Override 
     public void onResponse(ClusterStateResponse response) { 
      result.indexName = response.getState().getMetaData().aliases().get("alias").iterator().next().key; 

     } 
     @Override 
     public void onFailure(Throwable e) { 
      //Handle failures 
     } 
    }); 
    return result.value; 
} 

execute(), bir dinleyici alır biri için bir başka yöntem bulunmaktadır. Kendi dinleyicini uygulaman gerekiyor. Cevabımda, Dinleyici'nin anonim bir uygulamasına sahibim.

Bunu ben takma değerinden endeks adını almak mümkün bu, denedik