CaptureChangeMySQL cannot capture INSERT,UPDATE,DELETE

2020-01-02 Thread DC Gong
Hello, I've finished setting up CaptureChangeMySQL but I can't capture INSERT, UPDATE and DELETE However, DDL, begin, and commit are normally captured. I don't know what the problem is. I am using mariadb and I have used both mariadb jdbc driver and mysql jdbc driver, both of which do not

Re: Adding a Row Number to Records

2020-01-02 Thread Mike Thomsen
This looks pretty straight forward to do. Looks like all we'd have to do is update processRecord to take an index and make sure it's passed into the EL evaluation methods as part of the attribute map. On Thu, Jan 2, 2020 at 5:14 PM Matt Burgess wrote: > Shawn, > > This seems like something we

Re: Need help with DetectDuplicate

2020-01-02 Thread Matt Burgess
William, DistributedMapCacheClientService works in a standalone NiFi. Do you have a DistributedMapCacheServer configured for localhost:4557 and enabled? On Thu, Jan 2, 2020 at 4:39 PM William Gosse wrote: > > Will the DetectDuplicate with DistributedMapCacheClientService only work in a >

Re: 150 + if else on route on attributes

2020-01-02 Thread Matt Burgess
Asmath, Can you share more information about your use case? I'm curious to see if you need to use attributes at all, or if some combination of PartitionRecord and/or lookup controller services would work better. Thanks, Matt On Thu, Jan 2, 2020 at 4:43 PM KhajaAsmath Mohammed wrote: > > Hi, >

150 + if else on route on attributes

2020-01-02 Thread KhajaAsmath Mohammed
Hi, I have requirement where I need to do develop and parse json based on attribute value. This will eventually end up writing 150+ route on attributes. Is there a good approach to deal with it? Thanks, Asmath Sent from my iPhone

RE: Need help with DetectDuplicate

2020-01-02 Thread William Gosse
Will the DetectDuplicate with DistributedMapCacheClientService only work in a cluster? I’m trying to use it in a standalone NiFi. From: Emanuel Oliveira Sent: Tuesday, December 24, 2019 4:29 PM To: users@nifi.apache.org Subject: Re: Need help with DetectDuplicate [CAUTION: This email

Adding a Row Number to Records

2020-01-02 Thread Shawn Weeks
I have a use case where I need to append a row number to every record in a flow file. Not everything I receive is text so the only guarantee I have is that I have a record reader for each type of file. I started out looking at the row_number window function in QueryRecord but after looking at