METRON-421 Make Stellar Profiler Client API Accessible in Parser and Enrichment Topologies

Question

METRON-421

These changes were required to make the Stellar Profiler Client API accessible from the Parser and Enrichment topologies. - Added the metron-profiler-client as a dependency to the Parser and Enrichment topologies so that the Uber jar contains the Profiler Client API. - Added a README for the metron-profiler-client to describe its usage. - Pushing the metron-profiler-client archive to the Metron host to make the library accessible to the Stellar Shell. - Fixed an issue with potentially unsafe String to Bytes conversion that may cause issues on different platforms.

These changes can be manually tested by following the Getting Started instructions included in both the metron-profiler/README.md and metron-profiler-client/README.md.

该提问来源于开源项目：apache/metron

Answer 1

Daft.

Running org.apache.metron.enrichment.integration.EnrichmentIntegrationTest
SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in [jar:file:/home/travis/build/apache/incubator-metron/metron-analytics/metron-profiler-client/target/metron-profiler-client-0.2.0BETA.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/home/travis/.m2/repository/org/apache/logging/log4j/log4j-slf4j-impl/2.1/log4j-slf4j-impl-2.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/home/travis/.m2/repository/org/slf4j/slf4j-log4j12/1.7.10/slf4j-log4j12-1.7.10.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
32344 [Thread-12] ERROR b.s.d.worker - Error on initialization of server mk-worker
java.lang.ClassCastException: com.lmax.disruptor.BlockingWaitStrategy cannot be cast to org.apache.metron.lmax.metron-profiler.disruptor.WaitStrategy
    at backtype.storm.disruptor$disruptor_queue.doInvoke(disruptor.clj:51) ~[metron-profiler-client-0.2.0BETA.jar:?]
    at clojure.lang.RestFn.invoke(RestFn.java:494) ~[metron-profiler-client-0.2.0BETA.jar:?]
    at backtype.storm.daemon.worker$worker_data.invoke(worker.clj:199) ~[metron-profiler-client-0.2.0BETA.jar:?]
    at backtype.storm.daemon.worker$fn__7098$exec_fn__1236__auto__$reify__7100.run(worker.clj:428) ~[metron-profiler-client-0.2.0BETA.jar:?]
    at java.security.AccessController.doPrivileged(Native Method) ~[?:1.8.0_31]
    at javax.security.auth.Subject.doAs(Subject.java:422) ~[?:1.8.0_31]
    at backtype.storm.daemon.worker$fn__7098$exec_fn__1236__auto____7099.invoke(worker.clj:426) ~[metron-profiler-client-0.2.0BETA.jar:?]
    at clojure.lang.AFn.applyToHelper(AFn.java:178) ~[metron-profiler-client-0.2.0BETA.jar:?]
    at clojure.lang.AFn.applyTo(AFn.java:144) ~[metron-profiler-client-0.2.0BETA.jar:?]
    at clojure.core$apply.invoke(core.clj:624) ~[metron-profiler-client-0.2.0BETA.jar:?]
    at backtype.storm.daemon.worker$fn__7098$mk_worker__7175.doInvoke(worker.clj:409) [metron-profiler-client-0.2.0BETA.jar:?]
    at clojure.lang.RestFn.invoke(RestFn.java:512) [metron-profiler-client-0.2.0BETA.jar:?]
    at backtype.storm.daemon.supervisor$fn__7759.invoke(supervisor.clj:774) [metron-profiler-client-0.2.0BETA.jar:?]
    at clojure.lang.MultiFn.invoke(MultiFn.java:241) [metron-profiler-client-0.2.0BETA.jar:?]
    at backtype.storm.daemon.supervisor$sync_processes$iter__7577__7581$fn__7582$fn__7592.invoke(supervisor.clj:396) [metron-profiler-client-0.2.0BETA.jar:?]
    at backtype.storm.daemon.supervisor$sync_processes$iter__7577__7581$fn__7582.invoke(supervisor.clj:385) [metron-profiler-client-0.2.0BETA.jar:?]
    at clojure.lang.LazySeq.sval(LazySeq.java:40) [metron-profiler-client-0.2.0BETA.jar:?]
    at clojure.lang.LazySeq.seq(LazySeq.java:49) [metron-profiler-client-0.2.0BETA.jar:?]
    at clojure.lang.RT.seq(RT.java:484) [metron-profiler-client-0.2.0BETA.jar:?]
    at clojure.core$seq.invoke(core.clj:133) [?:?]
    at clojure.core$dorun.invoke(core.clj:2855) [?:?]
    at clojure.core$doall.invoke(core.clj:2871) [?:?]
    at backtype.storm.daemon.supervisor$sync_processes.invoke(supervisor.clj:383) [metron-profiler-client-0.2.0BETA.jar:?]
    at clojure.lang.AFn.applyToHelper(AFn.java:154) [metron-profiler-client-0.2.0BETA.jar:?]
    at clojure.lang.AFn.applyTo(AFn.java:144) [metron-profiler-client-0.2.0BETA.jar:?]
    at clojure.core$apply.invoke(core.clj:626) [?:?]
    at clojure.core$partial$fn__460.doInvoke(core.clj:2468) [?:?]
    at clojure.lang.RestFn.invoke(RestFn.java:397) [metron-profiler-client-0.2.0BETA.jar:?]
    at backtype.storm.event$event_manager$fn__7258.invoke(event.clj:40) [metron-profiler-client-0.2.0BETA.jar:?]
    at clojure.lang.AFn.run(AFn.java:22) [metron-profiler-client-0.2.0BETA.jar:?]
    at java.lang.Thread.run(Thread.java:745) [?:1.8.0_31]
32360 [Thread-12] ERROR b.s.util - Halting process: ("Error on initialization")