Uploaded image for project: 'Flume'
  1. Flume
  2. FLUME-3261

cant connect to es 5.x when x-pack or search-guard is enable

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Open
    • Priority: Blocker
    • Resolution: Unresolved
    • Affects Version/s: 1.8.0
    • Fix Version/s: 1.8.0
    • Component/s: Sinks+Sources
    • Labels:
      None
    • Release Note:
      Hide
      cant connect to es 5.x when x-pack or search-guard is enable
      flume log
      2018-07-25 15:59:34,595 (SinkRunner-PollingRunner-DefaultSinkProcessor) [ERROR - org.apache.flume.SinkRunner$PollingRunner.run(SinkRunner.java:158)] Unable to deliver event. Exception follows.
      NoNodeAvailableException[None of the configured nodes are available: [{#transport#-1}{Xc4C_dK7Tq6A-RbbSR82iw}{xx}{xx:9300}, {#transport#-2}{OPy0FXz5Rg-VT0VN5r6Bng}{xx}{xx:9300}, {#transport#-3}{eLhx6o-oQdqSzfCHx40NQQ}{xx}{xx:9300}, {#transport#-4}{XUjxR6I0QSmZX8yQYMEx-w}{xx}{xx:9300}, {#transport#-5}{2Um_uwAkSe6VIQnxlNG0gA}{xx}{xx:9300}]]
              at org.elasticsearch.client.transport.TransportClientNodesService.ensureNodesAreAvailable(TransportClientNodesService.java:344)
              at org.elasticsearch.client.transport.TransportClientNodesService.execute(TransportClientNodesService.java:242)
              at org.elasticsearch.client.transport.TransportProxyClient.execute(TransportProxyClient.java:59)
              at org.elasticsearch.client.transport.TransportClient.doExecute(TransportClient.java:366)
              at org.elasticsearch.client.support.AbstractClient.execute(AbstractClient.java:404)
              at org.elasticsearch.action.ActionRequestBuilder.execute(ActionRequestBuilder.java:80)
              at org.elasticsearch.action.ActionRequestBuilder.execute(ActionRequestBuilder.java:54)
              at org.apache.flume.sink.elasticsearch.client.ElasticSearchTransportClient.execute(ElasticSearchTransportClient.java:187)
              at org.apache.flume.sink.elasticsearch.ElasticSearchSink.process(ElasticSearchSink.java:217)
              at org.apache.flume.sink.DefaultSinkProcessor.process(DefaultSinkProcessor.java:67)
              at org.apache.flume.SinkRunner$PollingRunner.run(SinkRunner.java:145)
              at java.lang.Thread.run(Thread.java:745)
      Show
      cant connect to es 5.x when x-pack or search-guard is enable flume log 2018-07-25 15:59:34,595 (SinkRunner-PollingRunner-DefaultSinkProcessor) [ERROR - org.apache.flume.SinkRunner$PollingRunner.run(SinkRunner.java:158)] Unable to deliver event. Exception follows. NoNodeAvailableException[None of the configured nodes are available: [{#transport#-1}{Xc4C_dK7Tq6A-RbbSR82iw}{xx}{xx:9300}, {#transport#-2}{OPy0FXz5Rg-VT0VN5r6Bng}{xx}{xx:9300}, {#transport#-3}{eLhx6o-oQdqSzfCHx40NQQ}{xx}{xx:9300}, {#transport#-4}{XUjxR6I0QSmZX8yQYMEx-w}{xx}{xx:9300}, {#transport#-5}{2Um_uwAkSe6VIQnxlNG0gA}{xx}{xx:9300}]]         at org.elasticsearch.client.transport.TransportClientNodesService.ensureNodesAreAvailable(TransportClientNodesService.java:344)         at org.elasticsearch.client.transport.TransportClientNodesService.execute(TransportClientNodesService.java:242)         at org.elasticsearch.client.transport.TransportProxyClient.execute(TransportProxyClient.java:59)         at org.elasticsearch.client.transport.TransportClient.doExecute(TransportClient.java:366)         at org.elasticsearch.client.support.AbstractClient.execute(AbstractClient.java:404)         at org.elasticsearch.action.ActionRequestBuilder.execute(ActionRequestBuilder.java:80)         at org.elasticsearch.action.ActionRequestBuilder.execute(ActionRequestBuilder.java:54)         at org.apache.flume.sink.elasticsearch.client.ElasticSearchTransportClient.execute(ElasticSearchTransportClient.java:187)         at org.apache.flume.sink.elasticsearch.ElasticSearchSink.process(ElasticSearchSink.java:217)         at org.apache.flume.sink.DefaultSinkProcessor.process(DefaultSinkProcessor.java:67)         at org.apache.flume.SinkRunner$PollingRunner.run(SinkRunner.java:145)         at java.lang.Thread.run(Thread.java:745)
    • Docs Text:
      Hide
      this flume can use java high level rest client connect to es 5.x ?also add the user and password auth ,
      can connect to es http port 9200 not use transport client.

      Show
      this flume can use java high level rest client connect to es 5.x ?also add the user and password auth , can connect to es http port 9200 not use transport client.

      Description

      this flume can use java high level rest client connect to es 5.x ?also add the user and password auth , 
      can connect to es http port 9200 not use transport client. 

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              andy_zhou andyzhou
            • Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

              • Created:
                Updated: