Member since
02-01-2016
24
Posts
23
Kudos Received
5
Solutions
My Accepted Solutions
Title | Views | Posted |
---|---|---|
8831 | 04-02-2017 09:59 PM | |
2091 | 03-22-2017 07:08 PM | |
1728 | 12-26-2016 06:43 PM | |
3716 | 02-06-2016 12:29 AM | |
4917 | 02-02-2016 03:00 PM |
04-03-2017
12:22 AM
Thanks Meyer!!!
... View more
12-26-2016
06:43 PM
1 Kudo
@mayki wogno user defined arguments aren't really sent to ExecuteScript. If the value of the `filename` attribute is needed, it can be retrieved from the flow file itself. Below is an example of how to retrieve the `filename` attribute, update the attribute, and send the flow file to a `success` relationship. flowFile = session.get()
if (flowFile != None):
filename = flowFile.getAttribute("filename")
flowFile = session.putAttribute(flowFile, "filename", filename + "new_name")
session.transfer(flowFile, REL_SUCCESS)
For an example that is a little more in depth, you can download a template from this gist. For a deeper look into developing with NiFi, please see the developer's guide.
... View more
07-03-2018
05:05 AM
https://stackoverflow.com/questions/31233830/apache-spark-setting-spark-eventlog-enabled-and-spark-eventlog-dir-at-submit-or http://community.cloudera.com/t5/Advanced-Analytics-Apache-Spark/Spark-job-fails-in-cluster-mode/td-p/58772 if you want to use the keytab from inside a spark (cluster mode), copy the files using --files option and ALIAS. Then use relative path ./your.keytab
... View more