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

    • Bug
    • Status: Open
    • Blocker
    • Resolution: Unresolved
    • 1.8.0
    • 1.8.0
    • Sinks+Sources
    • None
    • 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)
    • 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

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

            Dates

              Created:
              Updated: