Acess來自Google Dataflow的彈性搜索實例

我試圖從我的Cloud Dataflow作業訪問我的雲彈性搜索節點。但它不可訪問。我收到以下例外。任何關於如何解決這個問題的建議都會有幫助謝謝。Acess來自Google Dataflow的彈性搜索實例

2016-01-06T19:12:02.573Z: Detail: (f157f8ce66961b12): Failed task is going to be retried. 
2016-01-06T19:12:49.825Z: Error: (3dc0d192c92b8043): NoNodeAvailableException[None of the configured nodes are available: [{#transport#-1}{xxx.yyy.aaa.bbb}{xxx.yyy.aaa.bbb:9300}]] 
at org.elasticsearch.client.transport.TransportClientNodesService.ensureNodesAreAvailable(TransportClientNodesService.java:290) 
    at org.elasticsearch.client.transport.TransportClientNodesService.execute(TransportClientNodesService.java:207) 
    at org.elasticsearch.client.transport.support.TransportProxyClient.execute(TransportProxyClient.java:55) 
    at org.elasticsearch.client.transport.TransportClient.doExecute(TransportClient.java:283) 
    at org.elasticsearch.client.support.AbstractClient.execute(AbstractClient.java:347) 
    at org.elasticsearch.action.ActionRequestBuilder.execute(ActionRequestBuilder.java:85) 
    at org.elasticsearch.action.ActionRequestBuilder.execute(ActionRequestBuilder.java:59) 
    at com.zu.bids.rt.dataflow.functions.ElasticSearchIO$CreateDocFromBqRowFn.processElement(ElasticSearchIO.java:77)

來源

2016-01-06 PraveenK

你可以ssh進入虛擬機並確認你可以手動到達有問題的地址嗎？ –

是的，我可以訪問這些虛擬機和數據流以外的彈性搜索。 – PraveenK

您可以從其中一個Dataflow VM訪問Elastic搜索嗎？ –

從數據流節點ssh ing使用（外部）ip地址或主機名失敗。在我的數據流中，我將IP地址更改爲節點名稱，它工作正常。我無法ping通IP地址。但使用主機名稱ping工程。

至少我的問題是通過在我的數據流作業中使用彈性搜索節點主機名來解決的。

來源

2016-01-06 20:46:23 PraveenK

Acess來自Google Dataflow的彈性搜索實例

回答

相關問題