Member since
04-27-2022
20
Posts
3
Kudos Received
0
Solutions
07-11-2024
10:03 AM
It's really just the same message as the original. (Un)fortunately, 2 of the 3 nodes of the cluster just dropped a few min ago so: 7/11/2024 16:57:12 UTC: Node disconnected due to org.apache.nifi.controller.serialization.FlowSynchronizationException: Failed to connect node to cluster because local flow controller partially updated. Administrator should disconnect node and review flow for corruption.
07/11/2024 16:57:12 UTC: Disconnection requested due to org.apache.nifi.controller.serialization.FlowSynchronizationException: Failed to connect node to cluster because local flow controller partially updated. Administrator should disconnect node and review flow for corruption.
07/11/2024 16:57:07 UTC: Node Status changed from CONNECTED to DISCONNECTED due to org.apache.nifi.controller.serialization.FlowSynchronizationException: Failed to connect node to cluster because local flow controller partially updated. Administrator should disconnect node and review flow for corruption.
07/11/2024 16:56:56 UTC: Received first heartbeat from connecting node. Node connected.
07/11/2024 16:56:54 UTC: Requesting that node connect to cluster
... View more
09-20-2023
06:58 AM
@kellerj, Has the reply helped resolve your issue? If so, can you please mark the appropriate reply as the solution, as it will make it easier for others to find the answer in the future? If you are still experiencing the issue, can you provide the information @TimothySpann has requested?
... View more
08-08-2023
12:01 PM
Yep! Had moved on to that after your response and written up a JIRA for my team to build the needed tool. Thanks again for the response. My plan is the below > Find all the processors which may have state, then check if each has state, and if so, clear it. Find processors of used types which can contain state: e.g., QueryDatabaseTableRecord For each, pull the state by the ID and check if it has any stored state if totalEntryCount of cluster or local state is non-zero If so, call the clear state endpoint Query URL: /nifi-api/flow/search-results?q=QueryDatabaseTableRecord Pull Processor State: /nifi-api/processors/41584e33-adc6-171d-0000-0000581caccb/state Clear Processor State: POST /nifi-api/processors/41584e33-adc6-171d-0000-0000581caccb/state/clear-requests
... View more
08-08-2023
08:54 AM
Sure. I had to make some extract it from a larger PG and make some adjustments due to key code being in a parameter. But the remainder of the parameters are really placeholders for your environment information. The main complication might be that I used a few external controller services that you will have to replace. But their names in the externalControllerServices JSON should help you replace them.
... View more
11-02-2022
11:51 AM
Disappointing, but what I was starting to suspect after going through CM's console. Is there general guidance on including those types of files to the NiFi nodes?
... View more
10-21-2022
12:34 PM
@kellerj Has the reply helped resolve your issue? If so, please mark the appropriate reply as the solution, as it will make it easier for others to find the answer in the future. Thanks
... View more
08-10-2022
04:43 PM
Thank you! I looked, but not in the right place. I skimmed over the bucket API, but didn't look in detail as I assumed (incorrectly) that it was not relevant to updating a flow.
... View more
08-01-2022
11:19 AM
1 Kudo
Thank you so much! I was looking around for the way to add arbitrary properties to the nifi-registry.properties and never hit on the right wording to find that one. Yep, figured I could always add the file manually if I could just do what you showed how to.
... View more
04-27-2022
03:46 PM
2 Kudos
I did end up finding a hacky way to do this. But something using APIs or the registry would be preferred. It was a multi-step process: Bring up a new NiFi server. Import the process group from the JSON file into the canvas. Stop the server and copy out flow.xml.gz Rebuild the server to get an empty flow.xml.gz, then stop it again. Unzip and edit both files. Copy the contents of the only <processorGroup> tag to replace the contents of the <rootGroup> Update the coordinates in the new root group to 0.0/0.0. Copy the <parameterContexts> over <parameterContexts/> in the new file. re-zip the updated file and start up the server. Re-enable broken controller services. Not pretty, but it worked to restore a server from a JSON export copy I had made with minimal fixes in NiFi itself. If there is no easier way, I hope this helps someone else.
... View more