hi @nshawa, I am having the following error on PutHiveStreaming processor after running the template you provided:   Any idea how to fix this? ... View more

I fiddled with the XML and I found that the issue is having data in form of XML attributes. For example if the longitude and latitude data is in this format, you get the desired output. Seems like there is some issue in the XMLReader. I upvoted your JIRA issue. Lets wait and see. Thanks for your response. ... View more

@Sneha Vadhi , can you please share your configuration for the connection between ReplaceText and ExecuteSQL ? Maybe a little tweak with the Back Pressure and Size Threshold might help you slow down the average load on NiFi. If you know the average size of each flowfile, you can decrease the threshold or backpressure threshold, so that the queue holds less number of flowfiles and after those files are processed, new files are queued. There is a Wait Processor for NiFi, but according to the documentation here, you'll have to setup a cache service on Couchbase or Redis. ... View more

@Sumit Das in my case, the problem was that Hive was not properly configured to support streaming. Basically transactions must be enabled but some others properties must be set as well. More info here: https://community.hortonworks.com/articles/49949/test-7.html The table must also respect some conditions (stored as ORC, transactional, bucketed). ... View more