Dear All, I am new not Zeppelin notebook, I have come across some strange behavior. 1. The variables and functions declared one notebook, can be accessible from another notebook. a. Why this feature is available ? b. How avoid this feature if possible ? c.How to clear the variables and the functions from the memory ? ... View more

Dear all, I have written user defined functions in Python / jython and executing them using executescript processor in Nifi. Till now everything went fine. Now in one my script I need to pass command line arguments to my scripts. Please tell me way to pass command line arguments for jython scripts. And also I would like know is there way to access property attributes from Nifi processor in my jython script in execute processor. ... View more

I am using the PutHiveSql to insert data into hive table. But it is very slow. It is approximately inserting each row in 2 to 3 secs. Is there a way to increase the speed of insertion ? It took around 3 days to insert 15000 rows ! please find below the puthiveQl processor configuration: Complete flow: ... View more

I have a data flow where I want read data from HDFS and write it to the hive table. My data flow: 1. GetHDFS 2. Split text ( split the file by 1 line, as each line is valid json string) 3. splitjson ( to read the requird josn object, in my case its is gyrodata) 4. evaluatejson ( to select the requird attributes from gyrodata json object) Next step have done after following the this answer ( here) 5.update attribute ( where i am setting the values for "hiveql.args.N.type" and "hiveql.args.N.value") as shown below 6.replacetext processor to write the insert statement "INSERT INTO TABLE gyroscope PARTITION(carbox_id ='Carboxtest') VALUES( ?, ?, ?, ?, ?,?, ?, ?);" I tried the insert statement ending with semicolumn and without semicolumn but same error 😞 7. puthiveql processor with below error ': please find below my complete flow : ... View more