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 wor
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 co
Shawn,
This seems like something we could do in UpdateRecord by supplying a
synthetic attribute called "record.index" or "record.number" or
something, so you can use Expression Language for updating the field.
It may also be possible to do something with Calcite and QueryRecord
but that might be o
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
> cluste
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,
>
>
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
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 originate
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 th