title: Acess Elastic search instance from Google Dataflow
body: <p>I am trying to access my cloud Elastic search nodes from my Cloud Dataflow job. But it is not accessible. I am getting the below exception. Any suggestions on how to fix this would help. Thanks.</p>
  
  <pre><code>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)
  </code></pre>