About nishantgupta101

nishantgupta101 · ‎02-01-2019

Hi @Matt Burgess I want to do something like this ${'$1':escapeJson()} as replacement value in replaceText processor search value being (?s)(^.*$) evaluation mode line-by-line bt this is not working as expected. can you please help if i need to replace each line of file with jsonescaped content

nishantgupta101 · ‎04-20-2018

Okay Hans !!!

nishantgupta101 · ‎04-18-2018

Hi, Did you get any solution to this ?. I am facing the same issue

nishantgupta101 · ‎04-16-2018

@Wynner No only windows end point is there as of now. Can it be achieved using ExecuteScript Processor in groovy or any other language.??

nishantgupta101 · ‎04-12-2018

nishantgupta101 · ‎04-12-2018

Still struggling in converting Bytes from Hbase to proper data type, when data is fetched using GetHBase processor in Nifi @Matt Burgess @Bryan Bende @Matt Clarke Thanks in advance

nishantgupta101 · ‎04-03-2018

Thanks @Matt Burgess I am already having the flow as GetHBase -> EvaluateJsonPath -> ReplaceText -> PutDatabaseRecord Where , GetHbase is getting data from hbase tablesEvaluateJsonPath is saving value in form of attributes ReplaceText is forming data in a line ${Name}, ${age}, ${city} PutDatabaseRecord is saving data in SQL data base. Issue is where my data contains value like "@\uFFFDs\uFFFD\uFFFD\u001E\uFFFD". (it should be some integer/double value) i am not able to figure it out which processor to use.. or anyother way to proceed.

nishantgupta101 · ‎03-29-2018

Bottleneck is I am getting the data from hbase in below format : "D:Field1":"@'\uFFFD\uFFFDQ\uFFFD\u001F" "D:Feild2":"@\uFFFDs\uFFFD\uFFFD\u001E\uFFFD" "D:Feild3":"@O\u0006fffff" "D:Feild4":"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" "D:Feild5":"\u0000\u0000\u0000\u0000\u0000\u0000\u0000H" This data is in this format because I am putting data in hbase using spark job and converting it in Bytes import org.apache.hadoop.hbase.util.Bytes input._2.foreach( record => { put.addColumn(Bytes.toBytes(builder.columnFamilyName),Bytes.toBytes(record._1),record._2.get.toBytes) })

nishantgupta101 · ‎03-01-2018

Getting error: 2018-03-01 21:06:17,923 WARN [Timer-Driven Process Thread-1] o.a.n.r.util.SiteToSiteRestApiClient Failed to get controller from https://hostname:9443/nifi-api due to org.apache.http.conn.HttpHostConnectException: Connect to hostname:9443 [hostname/xx.xx.xx.xx] failed: Connection timed out: connect

nishantgupta101 · ‎12-20-2017

Exporting nifi template to minifi config.yml template does not copy any reference to custom.properties. Is there any way to do that ?

nishantgupta101 · ‎12-20-2017

Hi Yolanda, Can you please let me know how to use custom properties in minifi ?

nishantgupta101 · ‎12-12-2017

Thnks Bryan

nishantgupta101 · ‎12-07-2017

If I do -> SELECT * FROM FLOWFILE WHERE Gender = 'Male', It works

nishantgupta101 · ‎12-07-2017

Hi, I want to do something like this SELECT * FROM FLOWFILE WHERE Gender = '${gender}' Need Help. Thanks

nishantgupta101 · ‎12-04-2017

I have a flow which does the following: 1. Fetches month startdate/enddate for each month for number of months configured 2. Monthly fetch the records from DB based on above startdate/endtime 3. Delete records in saved csv file in from previous 7 days 4. Add records with from previous 7 days to existing csv files. This flow contains approx 40 processors for which I have not yet done failure handling. How do I proceed with failure handling for each processor. Can please somebody let me know

nishantgupta101 · ‎11-14-2017

The issue that I was facing was in Nifi 1.3 I raised this issue with Apache team. They fixed it. https://issues.apache.org/jira/browse/MINIFI-403 Plus, you can try for Nifi 1.4 and Minifi 0.2.1, I am not facing issues now

nishantgupta101 · ‎09-21-2017

2017-09-21 11:56:10,887 ERROR [main] o.apache.nifi.controller.FlowController Unable to start FetchDistributedMapCache[id=c1c6c399-de22-31bb-0000-000000000000] due to java.lang.IllegalStateException: Processor FetchDistributedMapCache is not in a valid state due to ['Distributed Cache Service' validated against '8b7ad7d0-b049-36fd-0000-000000000000' is invalid because DistributedMapCacheClientService - 1.3.0 from org.apache.nifi - nifi-distributed-cache-services-nar is not compatible with DistributedMapCacheClient - unversioned from default - system] 2017-09-21 11:56:10,892 ERROR [main] o.apache.nifi.controller.FlowController Unable to start PutDistributedMapCache[id=cc0013ca-47f2-3120-0000-000000000000] due to java.lang.IllegalStateException: Processor PutDistributedMapCache is not in a valid state due to ['Distributed Cache Service' validated against '8b7ad7d0-b049-36fd-0000-000000000000' is invalid because DistributedMapCacheClientService - 1.3.0 from org.apache.nifi - nifi-distributed-cache-services-nar is not compatible with DistributedMapCacheClient - unversioned from default - system Does any body facing this issue. Help is appreciated

Online	Offline
Last Visited	‎03-12-2019 05:02 AM

Date Registered	‎09-21-2017 06:35 AM
Last Visited	‎03-12-2019 05:02 AM
Total Messages Posted	17

Re: Replace Line Feed character in Nifi

Re: Best approach to determine Oracle INSERT or UP...

Re: Best approach to determine Oracle INSERT or UP...

Re: How to send file through FTP in Nifi using SSL...

How to send file through FTP in Nifi using SSL ? (...

Re: How can I save my Hbase data to sql server usi...

Re: How can I save my Hbase data to sql server usi...

How can I save my Hbase data to sql server using N...

Not able to send file to nifi in edge node (cloud)...

How to use custom.properties in minifi ?

Re: Supporting Custom Properties for Expression La...

Re: How to give dynamic query in queryrecord proce...

Re: How to give dynamic query in queryrecord proce...

How to give dynamic query in queryrecord processor...

How do I manage failure for flow having 40+ proces...

Re: Running FetchDistributedMapCache/PutDistribute...

Running FetchDistributedMapCache/PutDistributedMap...