Member since
09-21-2017
17
Posts
0
Kudos Received
0
Solutions
02-01-2019
08:35 AM
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
... View more
04-20-2018
07:26 AM
Okay Hans !!!
... View more
04-18-2018
05:53 AM
Hi, Did you get any solution to this ?. I am facing the same issue
... View more
04-16-2018
03:24 PM
@Wynner No only windows end point is there as of now. Can it be achieved using ExecuteScript Processor in groovy or any other language.??
... View more
04-12-2018
10:46 AM
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
... View more
04-03-2018
09:24 AM
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.
... View more
03-29-2018
01:26 PM
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) })
... View more
Labels:
- Labels:
-
Apache HBase
-
Apache NiFi
03-01-2018
03:54 PM
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
... View more
Labels:
- Labels:
-
Apache NiFi
12-20-2017
07:44 AM
Exporting nifi template to minifi config.yml template does not copy any reference to custom.properties. Is there any way to do that ?
... View more
Labels:
- Labels:
-
Apache MiNiFi
-
Apache NiFi
12-20-2017
07:40 AM
Hi Yolanda, Can you please let me know how to use custom properties in minifi ?
... View more
12-12-2017
08:37 AM
Thnks Bryan
... View more
12-07-2017
01:09 PM
If I do -> SELECT * FROM FLOWFILE WHERE Gender = 'Male', It works
... View more
12-07-2017
01:07 PM
Hi, I want to do something like this SELECT * FROM FLOWFILE
WHERE Gender = '${gender}' Need Help. Thanks
... View more
Labels:
- Labels:
-
Apache NiFi
11-14-2017
09:27 AM
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
... View more
09-21-2017
11:24 PM
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
... View more
Labels:
- Labels:
-
Apache MiNiFi