Cassandra NoHostAvailableException: Tous hôte(s) essayé pour la requête a échoué dans la Production

Nous avons 10 Cassandra nœuds dans la production de l'exécution de Cassandra-2.1.8. Nous avons récemment mis à niveau à la version 2.1.8. Auparavant, nous étions à l'aide de seulement 3 noeuds Cassandra-2.1.2. Nous avons d'abord mis l'initiale de 3 nœuds à partir 2.1.2 2.1.8 (en suivant la procédure décrite dans La Mise À Niveau De Cassandra). Puis nous avons ajouté plus de 7 nœuds exécutant de Cassandra-2.1.8 en cluster. Puis nous avons commencé notre client des programmes. Pour les quelques premières heures, tout a bien fonctionné, mais après quelques heures, nous avons vu quelques erreurs dans le programme client de journaux comme

Thread-0 [29/07/15 17:41:23.356] ERROR  com.cleartrail.entityprofiling.engine.InterpretationWriter - Error:com.datastax.driver.core.exceptions.NoHostAvailableException: All host(s) tried for query failed (tried: [/172.50.33.161:9041, /172.50.33.162:9041, /172.50.33.95:9041, /172.50.33.96:9041, /172.50.33.165:9041, /172.50.33.166:9041, /172.50.33.163:9041, /172.50.33.164:9041, /172.50.33.42:9041, /172.50.33.167:9041] - use getErrors() for details)
at com.datastax.driver.core.exceptions.NoHostAvailableException.copy(NoHostAvailableException.java:65)
at com.datastax.driver.core.DefaultResultSetFuture.extractCauseFromExecutionException(DefaultResultSetFuture.java:259)
at com.datastax.driver.core.DefaultResultSetFuture.getUninterruptibly(DefaultResultSetFuture.java:175)
at com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:52)
at com.cleartrail.entityprofiling.engine.InterpretationWriter.WriteInterpretation(InterpretationWriter.java:430)
at com.cleartrail.entityprofiling.engine.Profiler.buildProfile(Profiler.java:1042)
at com.cleartrail.messageconsumer.consumer.KafkaConsumer.run(KafkaConsumer.java:336)
Caused by: com.datastax.driver.core.exceptions.NoHostAvailableException: All host(s) tried for query failed (tried: [/172.50.33.161:9041, /172.50.33.162:9041, /172.50.33.95:9041, /172.50.33.96:9041, /172.50.33.165:9041, /172.50.33.166:9041, /172.50.33.163:9041, /172.50.33.164:9041, /172.50.33.42:9041, /172.50.33.167:9041] - use getErrors() for details)
at com.datastax.driver.core.RequestHandler.sendRequest(RequestHandler.java:102)
at com.datastax.driver.core.RequestHandler$1.run(RequestHandler.java:176)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)

Maintenant, j'ai vérifié le Pare-feu (comme suggéré dans quelques postes), les ports, les délais d'attente des clients ainsi que les nœuds et ils sont tous corrects.

Je suis également pas de fermer la connexion n'importe où entre les deux. Je suis à l'aide de requêtes lot avec la taille des lots de 1000 et les requêtes sont des requêtes de mise à jour mise à jour des compteurs de mon tableau avec trois colonnes

entité , twfwv , cvalue

où l'entité et twfwv colonnes de texte et de clé primaire et de cvalue est contre la colonne.

J'ai même redémarré tous mes nœuds (parce que ce truc m'a aidé dans mon environnement de dev quand j'ai fait face à la même exception) mais sa n'aide pas. S'il vous plaît suggérer que peut-être le probable problème ici.

NoHostAvailableException est une erreur générique qui désigne tous les nœuds essayé par le pilote a échoué. Il serait utile de voir ce que les erreurs individuelles sont, pour cela vous avez besoin pour attraper l'exception dans votre code et d'inspecter le getErrors() champ. Sur une note de côté, qui pilote version utilisez-vous? Les versions les plus récentes devraient indiquer le premier des 3 erreurs dans le message principal.
Je suis à l'aide de com.datastax.cassandra cassandra-pilote-core version 2.1.2. D'ailleurs je vais essayer d'obtenir l'erreur exacte par la méthode getErrors (). Je vais poster la sortie une fois que je l'obtenir.
Le message d'erreur a été améliorée dans 2.1.4 (billet: JAVA-409). La dernière version est 2.1.7.1.
Oui j'ai mis à jour ma version du client et sera à l'aide de 2.1.7.1. Merci pour la mise à jour.

OriginalL'auteur abi_pat | 2015-07-29

3

Mon problème a été résolu par la vérification de la collection d'erreurs de NoHostAvailableException comme conseillé par Olivier Michallat dans les commentaires. Pour moi, c'était la version du protocole sur la configuration du cluster. La mienne est nulle, la valeur 3 fixe le problème.

OriginalL'auteur bitsprint

Vous devez vous connecter pour publier un commentaire.