Member since
12-01-2017
8
Posts
0
Kudos Received
0
Solutions
02-09-2018
04:11 PM
@Vasilis Vagias I am trying to create a data flow with nifi using python scripts. To begin the process I used ExecuteProcess processor and to execute subsequent scripts I am trying to use ExecuteScript processor.as I need to build dependency between my flow. I want the subsequent job to run only if the dependent job executes successfully. However, I see that the 'ExecuteProcess' jobs runs successfully but the subsequent 'ExecuteScript' jobs does not starts. I also see the relationship queue is empty. How can I make the flow run successfully. Here are the screenshots for your reference:
... View more
12-01-2017
07:25 PM
Thank you @Shu; it is running now.
... View more
12-01-2017
06:15 PM
@Shu This is what I see after running the commands
... View more
12-01-2017
05:56 PM
@Shu Thank you for quick response...I made the changes as suggested by you but now the processor is failing with below error: Caused by: java.io.IOException: PropertyDescriptor PropertyDescriptor[Directory] has invalid value /user/cmor/kinetica/files/sample_b.csv. The directory does not exist. Here is how the configuration of the processor looks: gethdfs.png
... View more
12-01-2017
05:16 PM
I am trying
to get files from HDFS directory with apache nifi GetHDFS processor; however, I
am getting the error in the nifi-app.log whenever I try to run the job Caused by:
java.lang.IllegalArgumentException: Wrong FS: hdfs://XXX:8020/user/sample_b.csv,
expected: file:/// at
org.apache.hadoop.fs.FileSystem.checkPath(FileSystem.java:649) Any one has
any idea what is causing the error?
... View more
Labels:
- Labels:
-
Apache Hadoop
-
Apache Kafka
-
Apache NiFi