Got it here: https://community.hortonworks.com/questions/64771/unable-to-updateexecute-processor-though-nifi-rest.html ... View more

this should help : https://community.hortonworks.com/questions/64771/unable-to-updateexecute-processor-though-nifi-rest.html ... View more

thank you so much.. i had issues with this curl dude.. had been searching for the correct command for over 3 days.. its working now.. 😄 ... View more

Hi Matt, I am working on this "curl" stuff but getting an error. I am using NiFi 1.0 Can you please see the below statements and let me know what I am missing? This works fine: curl -i -X GET http://localhost:8080/nifi-api/processors/1b943f28-3803-15dd-aec4-d362e560fbaf/state It gives a json as expected. ............................ This does not work: curl -i -X PUT -H 'Content-Type: application/json' -d '{"version":27,"clientId":"ddf4a732-0158-1000-419b-512493387a32"},"processors":{"id":"1b943f28-3803-15dd-aec4-362e560fbaf","state":"RUNNING"}' http://localhost:8080/nifi-api/processors/1b943f28-3803-15dd-aec4-d362e560fbaf/ This gives: HTTP/1.1 400 Bad Request Date: Wed, 21 Dec 2016 05:50:43 GMT Content-Type: text/plain Transfer-Encoding: chunked Server: Jetty(9.3.9.v20160517) Message body is malformed. Unable to map into expected format. ... View more

with your script, i wont even need to use Put and Fetch processors.. Just call ExecuteScript and let it add / update / delete from the CacheServer.. Thank you very much for your quick reply 😄 ... View more

any thoughts on how to clear this DMC cache.. Suppose I have 4 entries in DEPT_LKP table.. DEPT_NO 10, 20, 30, 40 get loaded to DMC.. in Future if i delete DEPT_NO 20 entry from source table.. DMC wont delete it from the cache.. worse part is.. it will use the cached value of DEPT_NO 20.. ... View more

I tried one more time and it worked for me.. thanks! ... View more

yeah thanks.. append works.. \\n (double backslash) doesnt.. I was doing this while writing count to file.. it now works.. The count is: ${executesql.row.count:append('\n')} ... View more

Hi Timothy, I am trying to Lookup with Cache method. Load the lookup values into the DistributedMapCache and use them for replacements PutDistributedMapCache FetchDistributedMapCache ----------- It doesnt seem to be working for me. When i try to compare values between 2 flows.. it doesnt compare them. I have a RouteOnAttribute which uses an Expression like this: ${DEPT_NO:equals(${LKP_DEPT_NO})} It doesnt send out anything. I checked the UpStream queues. They have correct values. Can you please suggest how to compare the incoming attributes from 2 flows? ... View more