Streamparse ejemplo de recuento de palabras
He estado queriendo usar Apache Storm para transmitir desde Kafka. Estoy más cómodo con Python, así que decidí usar streamparse (https://github.com/Parsely/streamparse) El ejemplo de conteo de palabras es el ejemplo introductorio. He estado tratando de que funcione en mi máquina local. Tengo instalada la siguiente versión de JDK, lein y storm:
Leiningen 2.6.1 on Java 1.8.0_73 Java HotSpot(TM) 64-Bit Server VM
Ejecuto los siguientes pasos después de seguir streamparse:
sparse quick start wordcount cd wordcount sparse run
Obtuve el siguiente error:
Retrieving org/apache/storm/storm-core/0.10.1/storm-core-0.10.1.pom from central Retrieving org/apache/storm/storm/0.10.1/storm-0.10.1.pom from central Retrieving org/apache/storm/storm-core/0.10.1/storm-core-0.10.1.jar from central Could not transfer artifact com.parsely:streamparse:pom:0.0.4-SNAPSHOT from/to clojars (https://clojars.org/repo/): sun.security.validator.ValidatorException: PKIX path building failed: sun.security.provider.certpath.SunCertPathBuilderException: unable to find valid certification path to requested target Could not transfer artifact clojure-complete:clojure-complete:pom:0.2.4 from/to clojars (https://clojars.org/repo/): sun.security.validator.ValidatorException: PKIX path building failed: sun.security.provider.certpath.SunCertPathBuilderException: unable to find valid certification path to requested target This could be due to a typo in :dependencies or network issues. If you are behind a proxy, try setting the 'http_proxy' environment variable.
Mi archivo project.clj dice así:
(defproject wordcount "0.0.1-SNAPSHOT" :source-paths ["topologies"] :resource-paths ["_resources"] :target-path "_build" :min-lein-version "2.6.1" :jvm-opts ["-client"] :dependencies [[org.apache.storm/storm-core "0.10.1"] [com.parsely/streamparse "0.0.4-SNAPSHOT"] ] :jar-exclusions [#"log4j\.properties" #"backtype" #"trident" #"META-INF" #"meta-inf" #"\.yaml"] :uberjar-exclusions [#"log4j\.properties" #"backtype" #"trident" #"META-INF" #"meta-inf" #"\.yaml"] )
Entonces, mis versiones lein y storm core están configuradas correctamente. No estoy seguro de dónde me estoy equivocando. ¿Alguien podría ayudarme?
-Gracias