Member since
12-20-2017
23
Posts
2
Kudos Received
1
Solution
My Accepted Solutions
Title | Views | Posted |
---|---|---|
5170 | 11-15-2017 01:34 PM |
06-01-2018
08:43 PM
@Felix Albani using --driver-class-path curator-client-2.7.1.jar for spark-submit has resolved the issue, thank you very much for your help!
... View more
06-01-2018
07:21 PM
@Felix Albani thank you for your answer, spark-shell in your sample works because it uses embedded PathUtils artifact: scala> classOf[PathUtils].getProtectionDomain().getCodeSource().getLocation()
res1: java.net.URL = file:/usr/hdp/2.6.4.0-91/spark/lib/spark-assembly-1.6.3.2.6.4.0-91-hadoop2.7.3.2.6.4.0-91.jar<br> In my sample I have only one dependency, so the issue can't be caused by the fat jar. Using --jars curator-client-2.7.1.jar with spark-submit doesn't resolve the issue.
... View more
06-01-2018
05:36 PM
Hello, artifact org.apache.curator, version 2.7.1 and higher doesn't work in a spark job. pom.xml file: <?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com.test</groupId>
<artifactId>test</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>jar</packaging>
<name>"test"</name>
<build>
<plugins>
<plugin>
<artifactId>maven-assembly-plugin</artifactId>
<executions>
<execution>
<id>test</id>
</execution>
</executions>
</plugin>
</plugins>
</build>
<dependencies>
<dependency>
<groupId>org.apache.curator</groupId>
<artifactId>curator-client</artifactId>
<version>2.7.1</version>
</dependency>
</dependencies>
</project>
Source code: cat src/main/java/com/test/Test.java
package com.test;
import org.apache.curator.utils.PathUtils;
public class Test {
public static void main(String[] args) throws Exception {
PathUtils.validatePath("/tmp");
}
}
The result is spark-submit --class com.test.Test --master local test-0.0.1-SNAPSHOT.jar
Exception in thread "main" java.lang.NoSuchMethodError: org.apache.curator.utils.PathUtils.validatePath(Ljava/lang/String;)Ljava/lang/String;
at com.test.Test.main(Test.java:7)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.apache.spark.deploy.SparkSubmit$.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:731)
at org.apache.spark.deploy.SparkSubmit$.doRunMain$1(SparkSubmit.scala:181)
at org.apache.spark.deploy.SparkSubmit$.submit(SparkSubmit.scala:206)
at org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:121)
at org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala)
The issue is replicated in spark version 1.6.2 and 2.2.0.2.6.4.0-91. Can you please help to resolve this issue?
... View more
Labels:
- Labels:
-
Apache Spark
04-05-2018
03:47 PM
1 Kudo
I'm using metron 0.4.3, to get the exact error that causes the issue you need to check the container's logs that are located on one of yarn nodes on
/hadoop/yarn/log/{application_id}/{containter_id}/stderr
... View more
04-03-2018
12:41 PM
1 Kudo
I had the same issue recently, the issue was resolved after I created rest.sh script.
The docs don't say much about this script, however the script is mandatory. https://github.com/apache/metron/tree/master/metron-analytics/metron-maas-service
https://gist.github.com/cestella/cba10aff0f970078a4c2c8cade3a4d1a
https://community.hortonworks.com/articles/149376/metron-model-as-a-service-maas-full-dev-platform.html
... View more
02-05-2018
05:28 PM
Labels:
- Labels:
-
Apache Metron
11-15-2017
01:34 PM
The issue is resolved by using -PHDP-2.5.0.0 option when I compile metron.
... View more
11-14-2017
07:26 PM
I'm facing following error, can you please help me to resolve it: 2017-11-14 16:39:55.489 o.a.s.util Thread-17-kafkaSpout-executor[4 4] [ERROR] Async loop died!
org.apache.kafka.common.KafkaException: Failed to construct kafka consumer
at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:702) ~[stormjar.jar:?]
at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:557) ~[stormjar.jar:?]
at org.apache.storm.kafka.spout.internal.KafkaConsumerFactoryDefault.createConsumer(KafkaConsumerFactoryDefault.java:26) ~[stormjar.jar:?]
at org.apache.storm.kafka.spout.KafkaSpout.subscribeKafkaConsumer(KafkaSpout.java:452) ~[stormjar.jar:?]
at org.apache.storm.kafka.spout.KafkaSpout.activate(KafkaSpout.java:445) ~[stormjar.jar:?]
at org.apache.storm.daemon.executor$fn__6505$fn__6520$fn__6551.invoke(executor.clj:646) ~[storm-core-1.0.1.2.5.5.0-157.jar:1.0.1.2.5.5.0-157]
at org.apache.storm.util$async_loop$fn__554.invoke(util.clj:484) [storm-core-1.0.1.2.5.5.0-157.jar:1.0.1.2.5.5.0-157]
at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_131]
Caused by: java.lang.IllegalArgumentException: No enum constant org.apache.kafka.common.protocol.SecurityProtocol.PLAINTEXTSASL
at java.lang.Enum.valueOf(Enum.java:238) ~[?:1.8.0_131]
at org.apache.kafka.common.protocol.SecurityProtocol.valueOf(SecurityProtocol.java:28) ~[stormjar.jar:?]
at org.apache.kafka.common.protocol.SecurityProtocol.forName(SecurityProtocol.java:89) ~[stormjar.jar:?]
at org.apache.kafka.clients.ClientUtils.createChannelBuilder(ClientUtils.java:79) ~[stormjar.jar:?]
at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:623) ~[stormjar.jar:?]
... 8 more
2017-11-14 16:39:55.495 o.a.s.d.executor Thread-17-kafkaSpout-executor[4 4] [ERROR]
org.apache.kafka.common.KafkaException: Failed to construct kafka consumer
at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:702) ~[stormjar.jar:?]
at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:557) ~[stormjar.jar:?]
at org.apache.storm.kafka.spout.internal.KafkaConsumerFactoryDefault.createConsumer(KafkaConsumerFactoryDefault.java:26) ~[stormjar.jar:?]
at org.apache.storm.kafka.spout.KafkaSpout.subscribeKafkaConsumer(KafkaSpout.java:452) ~[stormjar.jar:?]
at org.apache.storm.kafka.spout.KafkaSpout.activate(KafkaSpout.java:445) ~[stormjar.jar:?]
at org.apache.storm.daemon.executor$fn__6505$fn__6520$fn__6551.invoke(executor.clj:646) ~[storm-core-1.0.1.2.5.5.0-157.jar:1.0.1.2.5.5.0-157]
at org.apache.storm.util$async_loop$fn__554.invoke(util.clj:484) [storm-core-1.0.1.2.5.5.0-157.jar:1.0.1.2.5.5.0-157]
at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_131]
Caused by: java.lang.IllegalArgumentException: No enum constant org.apache.kafka.common.protocol.SecurityProtocol.PLAINTEXTSASL
at java.lang.Enum.valueOf(Enum.java:238) ~[?:1.8.0_131]
at org.apache.kafka.common.protocol.SecurityProtocol.valueOf(SecurityProtocol.java:28) ~[stormjar.jar:?]
at org.apache.kafka.common.protocol.SecurityProtocol.forName(SecurityProtocol.java:89) ~[stormjar.jar:?]
at org.apache.kafka.clients.ClientUtils.createChannelBuilder(ClientUtils.java:79) ~[stormjar.jar:?]
at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:623) ~[stormjar.jar:?]
... 8 more
... View more
Labels:
- Labels:
-
Apache Metron
10-17-2017
11:39 AM
Thank you, it has helped to resolve the issue.
... View more