Elasticsearch：私たちは私たちのプロジェクトに<strong>Elasticsearchプラグイン</strong>を使用していてAssertionError別名

Question

からインデックス名を取得中。エラーの下に、この問題の原因を

エラー

{ 
    "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 
    } 

コード

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

を取得別名からインデックス名を取得中？あなたが戻って結果を得るまでには、スレッドをブロックしますと、この操作は、トランスポートスレッド上で許可されていないように、それはエラーの表情からは任意のヘルプ

Answer 1

を取得していないグーグル、それはそうです。これを実行スレッド上で実行する必要があります。

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; 
} 

​​の別の方法があります。これはリスナーを取ります。独自のリスナーを実装する必要があります。私の答えでは、私はリスナーの匿名の実装を持っています。

は、私はそれが私が別名値からインデックス名を取得することができ、これを、試してみました