@Maxim Dashenko Perhaps when you are packaging your jar file is not adding the curator-client jar correctly to the fat jar. I tested the following and it works fine: 1. wget http://central.maven.org/maven2/org/apache/curator/curator-client/2.7.1/curator-client-2.7.1.jar 2. spark-shell --jar curator-client-2.7.1.jar 3. scala> import org.apache.curator.utils.PathUtils; import org.apache.curator.utils.PathUtils scala> PathUtils.validatePath("/tmp") No errors thrown while running the above. You can try adding the --jars and point to the jar file as well and see if that helps. spark-submit --jars curator-client-2.7.1.jar --class com.test.Test --master local test-0.0.1-SNAPSHOT.jar Otherwise I suggest you check your fat/uber jar. HTH *** If you found this answer addressed your question, please take a moment to login and click the "accept" link on the answer. ... View more

@RC Here is what I think you should use to make this work: -X POST use processor HTTP method attribute and set to POST -x http://proxyhost:port I think you should consider adding this configuration or add properties Proxy host=proxyhost, Proxy port=port and Proxy protocol=https -H "Accept: application/json" Use the Attributes to send referencing a new attribute with the value (add 1 extra attributes with corresponding value) -H "Content-Type: application/x-www-form-urlencoded" Use Content type attribute -d 'data sent' Send Message Body = true. And the content should come as inbound flowfile to the processor. To test try adding a GenerateFlowFile processor with the content without single quotes https://hostname/security/v1/oauth/token Set in Remote url Finally since endpoint is ssl enabled you need to set SSL Context Service. HTH *** If you found this answer addressed your question, please take a moment to login and click the "accept" link on the answer. ... View more

@chaouki trabelsi @Victor There are 2 approaches you can take. One is using package and the other is using jars (you need to download the jars) Package approach Add the following configuration on your zeppelin spark interpreter: spark.jars.packages = org.mongodb.spark:mongo-spark-connector_2.11:2.2.2 # for more information read here https://spark-packages.org/package/mongodb/mongo-spark Jar approach You need to add the mongo db connector jars to the spark interpreter configuration. 1. Download the mongodb connector jar for spark (depending on your spark version make sure you download the correct scala version - if spark2 you should use 2.11 scala) 2. Add the jars to the zeppelin spark interpreter using spark.jars property spark.jars = /location/of/jars On both cases you need to save and restart the interpreter. HTH *** If you found this answer addressed your question, please take a moment to login and click the "accept" link on the answer. ... View more