Streamparse wordcount exemple
J'ai eu envie de l'utilisation d'Apache Storm en continu à partir de Kafka. Je suis plus à l'aise avec Python, j'ai donc décidé d'utiliser streamparse (https://github.com/Parsely/streamparse). Le nombre de mots exemple est l'exemple dans l'introduction. J'ai essayé de le faire fonctionner sur ma machine locale. J'ai la suite de la version de JDK, lein et de la tempête installé:
Leiningen 2.6.1 sur Java 1.8.0_73 Java HotSpot(TM) 64-Bit Server VM
Je exécutez les étapes suivantes après avoir suivi streamparse:
éparses de démarrage rapide du nombre de mots cd wordcount éparses exécuter
J'obtiens l'erreur suivante:
La récupération org/apache/tempête/orage-core/0.10.1 l'a/storm-core-0.10.1 l'a.pom du centre de La récupération org/apache/storm/tempête/0.10.1 l'a/storm-0.10.1 l'a.pom du centre de La récupération org/apache/storm/storm-core/0.10.1/storm-core-0.10.1.jar du centre de Ne pouvait pas transférer artefact com.parsely:streamparse:pom:0.0.4-INSTANTANÉ à partir de/à clojars (https://clojars.org/repo/): le soleil.de sécurité.programme de validation.ValidatorException: PKIX chemin d'accès du bâtiment a échoué: le soleil.de sécurité.fournisseur de.certpath.SunCertPathBuilderException: impossible de trouver le chemin de certification valide à la demande de la cible Ne pouvait pas transférer artefact clojure-complète:clojure-complète:pom:0.2.4 à partir de/à clojars (https://clojars.org/repo/): le soleil.de sécurité.programme de validation.ValidatorException: PKIX chemin d'accès du bâtiment a échoué: le soleil.de sécurité.fournisseur de.certpath.SunCertPathBuilderException: impossible de trouver le chemin de certification valide à la demande de la cible Cela pourrait être dû à une faute de frappe dans :dépendances ou des problèmes de réseau. Si vous êtes derrière un proxy, essayez de définir le "http_proxy" environnement variable.
Mon projet.clj fichier se lit comme suit :
(defproject wordcount "0.0.1-SNAPSHOT" :source: chemins ["topologies"] :ressources chemins ["_resources"] :cible-chemin "_build" :min-lein-"version 2.6.1" :jvm-opts ["client"] :dépendances [[org.apache.tempête/orage-core "0.10.1 l'a"] [com.parsely/streamparse "0.0.4-SNAPSHOT"] ] :jar-exclusions [#"log4j\.les propriétés" #"backtype" #"trident" #"META-INF" #"meta-inf" #"\.yaml"] :uberjar-exclusions [#"log4j\.les propriétés" #"backtype" #"trident" #"META-INF" #"meta-inf" #"\.yaml"] )
Donc, mon lein et de la tempête versions de base sont définies correctement. Je ne suis pas sûr de l'endroit où je vais mal . Quelqu'un pourrait m'aider?
-Grâce
OriginalL'auteur red_devil | 2016-05-23
Vous devez vous connecter pour publier un commentaire.
C'est parce que java n'est pas reconnaissant certificat racine de l'autorité de certification (CA) certificat SSL de https://clojars.org/repo.
Solution est d'ajouter le certificat à java fichier cacerts de sorte qu'il était définitivement acceptée.
Etape 1 : Obtenir le certificat racine de https://clojars.org
C'est tout! vous avez obtenu votre certificat racine!
Étape 2 : Obtenir le certificat ajoutée à java fichier cacerts.
C'est elle! vous avez obtenu votre problème résolu.
VEUILLEZ NOTER
Faire confirmer que le jre qui est de vous donner ce PKIX erreur(JRE utilisé par KAFKA), qui est l'endroit où vous effectuez l'ÉTAPE 2. Si vous essayez avec un autre jre problème serait qu'il est.
N'utiliser qu'une seule jre qui est à l'intérieur du JDK il diminue la chance d'avoir des problèmes.
OriginalL'auteur positivecrux
Si vous utilisez debian ou ubuntu, vous pouvez exécuter la commande:
OriginalL'auteur jpalanco