I have Nifi set up on 6 nodes, I want to store one variable in DistributedMapCache, so I instert it with PutDistributedMapCache and then read it with FetchDistributedMapCache. However it works very unpredictably, most of the time fetch processor is unable to find that cache entry. I suppose it’s a problem with multiple nodes but according to documentation of DistributedMapCacheClientService “This can be used in order to share a Map between nodes in a NiFi cluster”. Another thing is that I start my flow with GenerateFlowFile that executes on primary node only and all my flowfiles are on node 1 so I’m not sure how is it supposed to work with DMC. I tested how it works when executed on all nodes and got weird results, 3/6 cache entries still could not be fetched.

I am new to NiFi and I have been trying to figure out if my use case is possible without writing custom scripts.

Does anyone know whether it is possible to disable the storing of content, but keep basic metadata (attributes) within the provenance.

In Apache Nifi I have an attribute timestamps which has a value:
[{"primary":{"apu":"2023-09-22T09:50:31.189489463Z","sop":"2024-03-15T08:20:02.540443877Z","zeq":"2023-09-22T09:50:31.189489463Z","wur":"2024-03-14T20:20:02.525785598Z"}}].
How can I access a nested key value based on another attribute value?

I am working with Apache NiFi and I need to configure parameters dynamically based on environment variables. I understand that NiFi has a Parameter Context feature, but I am not sure how to directly reference environment variables within this context.

I’m trying to host a standalone instance of NiFi Server on a VM.

I have a scenario, that, i have one flow file with csv content as data with tab a column separator. Below is the flow file content
test.txt

In Apache Nifi there are controller services for scripted rules processing: ScriptedActionHandler, ScriptedRulesEngine.

Example:

I have nifi running,and its cluster stats has following readings: