Java ElasticSearch aucun des nœuds configurés n'est disponible

Vient de télécharger et d'installer elasticsearch 1.3.2 dans la dernière heure

Tables IP ouvertes au port 9200 et 9300: 9400

Définit le nom et l'adresse ip de mon ordinateur dans /etc/hosts

Module de tête et paramédic installé et fonctionne bien

Curl sur localhost fonctionne sans faille

Copié tous les jars du téléchargement dans eclipse donc même client de version

--Java--

import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.Client;
import org.elasticsearch.client.transport.TransportClient;
import org.elasticsearch.common.settings.ImmutableSettings;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.transport.InetSocketTransportAddress;
import org.elasticsearch.index.query.QueryBuilders;


public class Test{         
    public static void main(String[] args) {
        Settings settings = ImmutableSettings.settingsBuilder().put("cluster.name", "elastictest").build();
            TransportClient transportClient = new TransportClient(settings);
                Client client = transportClient.addTransportAddress(new InetSocketTransportAddress("143.79.236.xxx",9300));//just masking ip with xxx for SO Question

            try{
                SearchResponse response = client.prepareSearch().setQuery(QueryBuilders.matchQuery("url", "twitter")).setSize(5).execute().actionGet();//bunch of urls indexed
                    String output = response.toString();
                        System.out.println(output);
            }catch(Exception e){
                e.printStackTrace();
            }
                client.close();
        }
}

--Sortie--

log4j:WARN No appenders could be found for logger (org.elasticsearch.plugins).
log4j:WARN Please initialize the log4j system properly.
log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info.
org.elasticsearch.client.transport.NoNodeAvailableException: None of the configured nodes are available: []
    at org.elasticsearch.client.transport.TransportClientNodesService.ensureNodesAreAvailable(TransportClientNodesService.java:298)
    at org.elasticsearch.client.transport.TransportClientNodesService.execute(TransportClientNodesService.java:214)
    at org.elasticsearch.client.transport.support.InternalTransportClient.execute(InternalTransportClient.java:105)
    at org.elasticsearch.client.support.AbstractClient.search(AbstractClient.java:330)
    at org.elasticsearch.client.transport.TransportClient.search(TransportClient.java:421)
    at org.elasticsearch.action.search.SearchRequestBuilder.doExecute(SearchRequestBuilder.java:1097)
    at org.elasticsearch.action.ActionRequestBuilder.execute(ActionRequestBuilder.java:91)
    at org.elasticsearch.action.ActionRequestBuilder.execute(ActionRequestBuilder.java:65)
    at Test.main(Test.java:20)

Mise À JOUR: Maintenant, je suis vraiment confus. Je juste pressé exécuter dans eclipse 3 fois. 2 fois reçu l'erreur ci-dessus. 1 fois que la recherche a fonctionné!?? Marque Nouveau Centos 6.5 vps, marque nouveau JDK installé. Ensuite, Elasticsearch installé, n'a rien fait d'autre à boxer.

Mise à Jour: Après l'exécution ./bin / Elasticsearch console 

[2014-09-18 08:56:13,694][INFO ][node                     ] [Acrobat] version[1.3.2], pid[2978], build[dee175d/2014-08-13T14:29:30Z]
[2014-09-18 08:56:13,695][INFO ][node                     ] [Acrobat] initializing ...
[2014-09-18 08:56:13,703][INFO ][plugins                  ] [Acrobat] loaded [], sites [head, paramedic]
[2014-09-18 08:56:15,941][WARN ][common.network           ] failed to resolve local host, fallback to loopback
java.net.UnknownHostException: elasticsearchtest: elasticsearchtest: Name or service not known
        at java.net.InetAddress.getLocalHost(InetAddress.java:1473)
        at org.elasticsearch.common.network.NetworkUtils.<clinit>(NetworkUtils.java:54)
        at org.elasticsearch.transport.netty.NettyTransport.<init>(NettyTransport.java:204)
        at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
        at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:57)
        at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
        at java.lang.reflect.Constructor.newInstance(Constructor.java:526)
        at org.elasticsearch.common.inject.DefaultConstructionProxyFactory$1.newInstance(DefaultConstructionProxyFactory.java:54)
        at org.elasticsearch.common.inject.ConstructorInjector.construct(ConstructorInjector.java:86)
        at org.elasticsearch.common.inject.ConstructorBindingImpl$Factory.get(ConstructorBindingImpl.java:98)
        at org.elasticsearch.common.inject.ProviderToInternalFactoryAdapter$1.call(ProviderToInternalFactoryAdapter.java:45)
        at org.elasticsearch.common.inject.InjectorImpl.callInContext(InjectorImpl.java:837)
        at org.elasticsearch.common.inject.ProviderToInternalFactoryAdapter.get(ProviderToInternalFactoryAdapter.java:42)
        at org.elasticsearch.common.inject.Scopes$1$1.get(Scopes.java:57)
        at org.elasticsearch.common.inject.InternalFactoryToProviderAdapter.get(InternalFactoryToProviderAdapter.java:45)
        at org.elasticsearch.common.inject.FactoryProxy.get(FactoryProxy.java:52)
        at org.elasticsearch.common.inject.ProviderToInternalFactoryAdapter$1.call(ProviderToInternalFactoryAdapter.java:45)
        at org.elasticsearch.common.inject.InjectorImpl.callInContext(InjectorImpl.java:837)
        at org.elasticsearch.common.inject.ProviderToInternalFactoryAdapter.get(ProviderToInternalFactoryAdapter.java:42)
        at org.elasticsearch.common.inject.Scopes$1$1.get(Scopes.java:57)
        at org.elasticsearch.common.inject.InternalFactoryToProviderAdapter.get(InternalFactoryToProviderAdapter.java:45)
        at org.elasticsearch.common.inject.SingleParameterInjector.inject(SingleParameterInjector.java:42)
        at org.elasticsearch.common.inject.SingleParameterInjector.getAll(SingleParameterInjector.java:66)
        at org.elasticsearch.common.inject.ConstructorInjector.construct(ConstructorInjector.java:85)
        at org.elasticsearch.common.inject.ConstructorBindingImpl$Factory.get(ConstructorBindingImpl.java:98)
        at org.elasticsearch.common.inject.ProviderToInternalFactoryAdapter$1.call(ProviderToInternalFactoryAdapter.java:45)
        at org.elasticsearch.common.inject.InjectorImpl.callInContext(InjectorImpl.java:837)
        at org.elasticsearch.common.inject.ProviderToInternalFactoryAdapter.get(ProviderToInternalFactoryAdapter.java:42)
        at org.elasticsearch.common.inject.Scopes$1$1.get(Scopes.java:57)
        at org.elasticsearch.common.inject.InternalFactoryToProviderAdapter.get(InternalFactoryToProviderAdapter.java:45)
        at org.elasticsearch.common.inject.SingleParameterInjector.inject(SingleParameterInjector.java:42)
        at org.elasticsearch.common.inject.SingleParameterInjector.getAll(SingleParameterInjector.java:66)
        at org.elasticsearch.common.inject.ConstructorInjector.construct(ConstructorInjector.java:85)
        at org.elasticsearch.common.inject.ConstructorBindingImpl$Factory.get(ConstructorBindingImpl.java:98)
        at org.elasticsearch.common.inject.FactoryProxy.get(FactoryProxy.java:52)
        at org.elasticsearch.common.inject.ProviderToInternalFactoryAdapter$1.call(ProviderToInternalFactoryAdapter.java:45)
        at org.elasticsearch.common.inject.InjectorImpl.callInContext(InjectorImpl.java:837)
        at org.elasticsearch.common.inject.ProviderToInternalFactoryAdapter.get(ProviderToInternalFactoryAdapter.java:42)
        at org.elasticsearch.common.inject.Scopes$1$1.get(Scopes.java:57)
        at org.elasticsearch.common.inject.InternalFactoryToProviderAdapter.get(InternalFactoryToProviderAdapter.java:45)
        at org.elasticsearch.common.inject.SingleParameterInjector.inject(SingleParameterInjector.java:42)
        at org.elasticsearch.common.inject.SingleParameterInjector.getAll(SingleParameterInjector.java:66)
        at org.elasticsearch.common.inject.ConstructorInjector.construct(ConstructorInjector.java:85)
        at org.elasticsearch.common.inject.ConstructorBindingImpl$Factory.get(ConstructorBindingImpl.java:98)
        at org.elasticsearch.common.inject.ProviderToInternalFactoryAdapter$1.call(ProviderToInternalFactoryAdapter.java:45)
        at org.elasticsearch.common.inject.InjectorImpl.callInContext(InjectorImpl.java:837)
        at org.elasticsearch.common.inject.ProviderToInternalFactoryAdapter.get(ProviderToInternalFactoryAdapter.java:42)
        at org.elasticsearch.common.inject.Scopes$1$1.get(Scopes.java:57)
        at org.elasticsearch.common.inject.InternalFactoryToProviderAdapter.get(InternalFactoryToProviderAdapter.java:45)
        at org.elasticsearch.common.inject.InjectorBuilder$1.call(InjectorBuilder.java:200)
        at org.elasticsearch.common.inject.InjectorBuilder$1.call(InjectorBuilder.java:193)
        at org.elasticsearch.common.inject.InjectorImpl.callInContext(InjectorImpl.java:830)
        at org.elasticsearch.common.inject.InjectorBuilder.loadEagerSingletons(InjectorBuilder.java:193)
        at org.elasticsearch.common.inject.InjectorBuilder.injectDynamically(InjectorBuilder.java:175)
        at org.elasticsearch.common.inject.InjectorBuilder.build(InjectorBuilder.java:110)
        at org.elasticsearch.common.inject.Guice.createInjector(Guice.java:93)
        at org.elasticsearch.common.inject.Guice.createInjector(Guice.java:70)
        at org.elasticsearch.common.inject.ModulesBuilder.createInjector(ModulesBuilder.java:59)
        at org.elasticsearch.node.internal.InternalNode.<init>(InternalNode.java:192)
        at org.elasticsearch.node.NodeBuilder.build(NodeBuilder.java:159)
        at org.elasticsearch.bootstrap.Bootstrap.setup(Bootstrap.java:70)
        at org.elasticsearch.bootstrap.Bootstrap.main(Bootstrap.java:203)
        at org.elasticsearch.bootstrap.Elasticsearch.main(Elasticsearch.java:32)
Caused by: java.net.UnknownHostException: elasticsearchtest: Name or service not known
        at java.net.Inet6AddressImpl.lookupAllHostAddr(Native Method)
        at java.net.InetAddress$1.lookupAllHostAddr(InetAddress.java:901)
        at java.net.InetAddress.getAddressesFromNameService(InetAddress.java:1293)
        at java.net.InetAddress.getLocalHost(InetAddress.java:1469)
        ... 62 more
[2014-09-18 08:56:16,937][INFO ][node                     ] [Acrobat] initialized
[2014-09-18 08:56:16,937][INFO ][node                     ] [Acrobat] starting ...
[2014-09-18 08:56:17,110][INFO ][transport                ] [Acrobat] bound_address {inet[/0:0:0:0:0:0:0:0:9300]}, publish_address {inet[/143.79.236.31:9300]}
[2014-09-18 08:56:17,126][INFO ][discovery                ] [Acrobat] elastictest/QvSNFajjQ9SFjU7WOdjaLw
[2014-09-18 08:56:20,145][INFO ][cluster.service          ] [Acrobat] new_master [Acrobat][QvSNFajjQ9SFjU7WOdjaLw][localhost][inet[/143.79.236.31:9300]], reason: zen-disco-join (elected_as_master)
[2014-09-18 08:56:20,212][INFO ][http                     ] [Acrobat] bound_address {inet[/0:0:0:0:0:0:0:0:9200]}, publish_address {inet[/143.79.236.31:9200]}
[2014-09-18 08:56:20,214][INFO ][node                     ] [Acrobat] started

--configuration du cluster dans elasticsearch.yml-- 

################################### Cluster ###################################

# Cluster name identifies your cluster for auto-discovery. If you're running
# multiple clusters on the same network, make sure you're using unique names.
#
cluster.name: elastictest
41
demandé sur Chris 2014-09-18 16:25:45

12 réponses

Les paramètres Elasticsearch sont dans $ES_HOME/config/elasticsearch.yml. Là, si le paramètre cluster.name est commenté, cela signifie que ES prendrait à peu près n'importe quel nom de cluster. Donc, dans votre code, le cluster.name comme "elastictest" pourrait être le problème. Essayez ceci: 

Client client = new TransportClient()
                .addTransportAddress(new InetSocketTransportAddress(
                        "143.79.236.xxx",
                        9300));
32
répondu Aritra 2016-01-05 15:38:20

Problème Possible:

  1. mauvais port, si vous utilisez un client Java ou Scala, le port correct est 9300, pas 9200
  2. mauvais nom de cluster, assurez-vous que le nom de cluster que vous avez défini dans votre code est le même que cluster.name vous définissez dans $ES_HOME/config/elasticsearch.yml
  3. l'option sniff, définie sur client.transport.sniff sur true mais impossible de se connecter à tous les nœuds du cluster ES, causera également ce problème. ES doc ici a expliqué pourquoi.
27
répondu backingwu 2016-05-02 05:12:38

Vous devriez vérifier le port du nœud, vous pouvez le faire en utilisant head. Ces ports ne sont pas les mêmes. Exemple,

L'URL web que vous pouvez ouvrir est localhost:9200, mais le port du nœud est 9300, donc aucun des nœuds configurés n'est disponible si vous utilisez le {[2] } comme port.

13
répondu fmyblack 2016-01-05 15:37:43

Pour l'achèvement, voici l'extrait qui crée le client de transport en utilisant la méthode statique appropriée fournie par InetSocketTransportAddress: 

    Client esClient = TransportClient.builder()
        .settings(settings)
        .build()
        .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("143.79.236.xxx"), 9300));
3
répondu Philip M. 2016-01-15 22:30:47

Si les conseils ci-dessus ne fonctionnent pas pour vous, modifiez le niveau de journalisation de votre configuration d'infrastructure de journalisation (log4j, logback...) à INFO . Puis re-vérifiez la sortie.

L'enregistreur peut masquer des messages comme: 

INFO  org.elasticsearch.client.transport.TransportClientNodesService - failed to get node info for...
Caused by: ElasticsearchSecurityException: missing authentication token for action...

(dans l'exemple ci-dessus, il y avait un plugin X-Pack dans ElasticSearch qui nécessite une authentification)

3
répondu Dimitar II 2016-11-14 22:05:00

Face à un problème similaire, et voici la solution

Exemple :

  1. Dans elasticsearch.YML Ajoute les propriétés ci-dessous 

    cluster.name: production
node.name: node1
network.bind_host: 10.0.1.22
network.host: 0.0.0.0
transport.tcp.port: 9300

  2. Ajoutez ce qui suit dans Java Elastic API pour Bulk Push (juste un extrait de code). Pour L'adresse IP ajouter l'adresse IP publique de la machine de recherche elastic 

    Client client;
BulkRequestBuilder requestBuilder;
try {
    client = TransportClient.builder().settings(Settings.builder().put("cluster.name", "production").put("node.name","node1")).build().addTransportAddress(
    new InetSocketTransportAddress(InetAddress.getByName(""), 9300));
    requestBuilder = (client).prepareBulk();
} 
catch (Exception e) {
}

  3. Ouvrez les ports du pare-feu pour 9200,9300

3
répondu Anantha 2017-06-08 13:07:25 
NoNodeAvailableException[None of the configured nodes are available: [{#transport#-1}{UfB9geJCR--spyD7ewmoXQ}{192.168.1.245}{192.168.1.245:9300}]]

Dans mon cas, c'était la différence dans les versions. Si vous vérifiez les journaux dans le cluster elasticsearch, vous verrez.

Journaux Elasticsearch 

[node1] exception caught on transport layer [NettyTcpChannel{localAddress=/192.168.1.245:9300, remoteAddress=/172.16.1.47:65130}], closing connection
java.lang.IllegalStateException: Received message from unsupported version: [5.0.0] minimal compatible version is: [5.6.0]

J'utilisais le client elasticsearch et la version de transport 5.1.1. Et ma version du cluster elasticsearch était en 6. Je change donc la version de ma bibliothèque en 5.4.3.

2
répondu dush 2018-08-13 09:55:06

Pour les autres utilisateurs qui obtiennent ce problème.

Vous pouvez obtenir cette erreur si vous exécutez un Elasticsearch plus récent (5.5 ou ultérieur) lors de L'exécution de la version Spring Boot

La recommandation est d'utiliser le Client REST puisque le Client Java sera obsolète.

Une autre solution serait de mettre à niveau vers Spring Boot 2, car cela devrait être compatible.

Voir https://discuss.elastic.co/t/spring-data-elasticsearch-cant-connect-with-elasticsearch-5-5-0/94235 pour de plus amples informations.

1
répondu nesohc 2018-04-16 14:47:06

Celui-ci a fonctionné pour moi dans ES 1.7.5: 

import org.elasticsearch.action.index.IndexResponse;
import org.elasticsearch.client.Client;
import org.elasticsearch.client.transport.TransportClient;
import org.elasticsearch.common.settings.ImmutableSettings;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.transport.InetSocketTransportAddress;
import org.elasticsearch.common.xcontent.XContentBuilder;

public static void main(String[] args) throws IOException  {
    Settings settings = ImmutableSettings.settingsBuilder()
            .put("client.transport.sniff",true)
            .put("cluster.name","elasticcluster").build();

    Client client = new TransportClient(settings)
            .addTransportAddress(new InetSocketTransportAddress("[ipaddress]",9300));
    XContentBuilder builder = null;
    try {
        builder = jsonBuilder().startObject().field("user", "testdata").field("postdata",new Date()).field("message","testmessage")
                .endObject();
    } catch (IOException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }

    System.out.println(builder.string());

    IndexResponse response = client.prepareIndex("twitter","tweet","1").setSource(builder).execute().actionGet();

    client.close();

}

0
répondu BenCes 2017-01-24 09:56:27

Vérifiez votre elasticsearch.yml, "le transport.accueil" propriété doit être "0.0.0.0" pas "127.0.0.1" ou "localhost"

0
répondu Romain DEQUIDT 2018-01-11 10:40:59

Cela signifie que nous ne sommes pas en mesure d'instancier es transportClient et de lancer cette exception. Il y a quelques possibilités qui causent ce problème.

  • le nom du Cluster est incorrect. Alors ouvrez le fichier ES_HOME_DIR/config/elasticserach.yml et vérifiez la valeur du nom du cluster ou utilisez cette commande: curl -XGET 'http://localhost:9200/_nodes'
  • vérifiez que le port 9200 est le port http mais que le service elasticsearch utilise le port tcp 9300 [par défaut]. Vérifiez donc que le port n'est pas bloqué.

  • Problème D'authentification: définissez l'en-tête dans transportclient's contexte d'authentification: 

    client.threadPool().getThreadContext()
  .putHeader("Authorization", "Basic " + encodeBase64String(basicHeader.getBytes()));

Si vous êtes toujours confronté à ce problème, ajoutez la propriété suivante: 

put("client.transport.ignore_cluster_name", true)

Le code de base ci-dessous fonctionne bien pour moi: 

Settings settings = Settings.builder()
            .put("cluster.name", "my-application").put("client.transport.sniff", true).put("client.transport.ignore_cluster_name", false).build();
    TransportClient client = new PreBuiltTransportClient(settings).addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9300));
0
répondu Rajeev Rathor 2018-03-10 12:07:09

Si vous utilisez java Transport client 1.la vérification 9300 est accessible / ouverte. 2.vérifiez le nom du nœud et du cluster, cela devrait être le bon, vous pouvez vérifier le nom du nœud et du cluster par type ip: port dans votre navigateur. 3.Vérifiez les versions de votre jar et Es version installée.

0
répondu prasad kp 2018-09-26 10:26:04