Member since
03-10-2017
171
Posts
80
Kudos Received
32
Solutions
My Accepted Solutions
| Title | Views | Posted |
|---|---|---|
| 1535 | 08-12-2024 08:42 AM | |
| 2454 | 05-30-2024 04:11 AM | |
| 3244 | 05-29-2024 06:58 AM | |
| 2242 | 05-16-2024 05:05 AM | |
| 1589 | 04-23-2024 01:46 AM |
01-22-2026
06:53 AM
Apache NiFi 2.X or CFM Version 4.X now provide an ability to use Bitbucket as flow version control in place of NiFi Registry.
This new Registry Client is built with the name BitbucketFlowRegistryClient to connect to Bitbucket
To set up BitbucketFlowRegistryClient following information is required from the Bitbucket account as a prerequisite; if not present must be created
Workspace Name
Repository Name
Authentication Type
Default Branch
Repository Path
For this article Authentication Type is set to Access Token. This user needs to make sure the Access token is generated and kept handy from the Repository settings page in Bitbucket. Also, the user needs to make sure the Repository permissions are set up properly with Read and Write access on the Repository
BitbucketFlowRegistryClient also needs StandardWebClientServiceProvider in the very first place as a Web Client Service to create an HTTP web client to connect to the Bitbucket API
Once StandardWebClientServiceProvider is created and enabled from the Management Controller Services. From the Registry Client, add BitbucketFlowRegistryClient and configure.
StandardWebClientServiceProvider and other property values as captured from Bitbucket as a prerequisite, and apply and enable the BitbucketFlowRegistryClient
After this, go and create a Process Group in NiFi if it has not been created before or if there are Process Groups created and a flow built inside, just right-click on the Process Group and click on Version with Start Version Control.
This action will open the Save flow version page, where the user can provide the Flow Name, Flow Description, and Version Comments, and save it
Upon Successful Versioning, the Process Group should have the right check mark icon in Green Colour at the top left corner.
And, the following entry should be updated in the BitBucket UI
Once the flow is published to BitBucket UI, and if there are further changes in the flow inside the Versioned process group, then the process group version icon will change from the right check to the gear icon, with Version menu items now showing (Commit/Show/Revert local changes /Stop version Control).
Upon Commit Local Changes, the user will be prompted to add comments regarding the new version.
Upon successful save, the BitBucket UI should show updated Version details:
At this point, the flows can be deployed into NiFi from BitBucket through version control. To do this use click on the Import from Registry icon in the NiFi UI
Import from the Registry window should show all the versions of the flow that were published in earlier steps into BitBucket. Select the desired version and import the from Into NiFi from BitBucket.
Note: Apache NiFi 2.7.2 version is used to prepare the snapshots, few properties may vary between Apache NiFi 2.X vs CFM 4.X, but all the required ones are there.
Thank you
... View more
Labels:
08-11-2025
09:05 PM
1 Kudo
This article provides detailed steps about Encrypting and Decrypting files using the Pretty Good Privacy (PGP) algorithm in NiFi
Steps involve :
Setting up GPG private key and Public key
Creating NiFi flow
Setting up GPG private key and Public key
Set up the GPG home directory export GNUPGHOME=/tmp/gnupg
Generate a private and public key with a user ID gpg --full-generate-key
gpg (GnuPG) 2.2.20; Copyright (C) 2020 Free Software Foundation, Inc.
This is free software: you are free to change and redistribute it.
There is NO WARRANTY, to the extent permitted by law.
Please select what kind of key you want:
(1) RSA and RSA (default)
(2) DSA and Elgamal
(3) DSA (sign only)
(4) RSA (sign only)
(14) Existing key from card
Your selection? 1
RSA keys may be between 1024 and 4096 bits long.
What keysize do you want? (2048) 2048
Requested keysize is 2048 bits
Please specify how long the key should be valid.
0 = key does not expire
<n> = key expires in n days
<n>w = key expires in n weeks
<n>m = key expires in n months
<n>y = key expires in n years
Key is valid for? (0) 0
Key does not expire at all
Is this correct? (y/N) y
GnuPG needs to construct a user ID to identify your key.
Real name: TestXYZ
Email address: test@example.com
Comment:
You selected this USER-ID:
"TestXYZ <test@example.com>"
Change (N)ame, (C)omment, (E)mail or (O)kay/(Q)uit? o
There will be a prompt to enter a passphrase, which will be used later in the configuration
There will be 4 files created under /tmp/gnupg
Create a public and private keyring file in ASCII format
For the public keyring file, run the following command gpg --export --armor --output testexample.gpg.pub test@example.com
For the Private keyring file, run the following command gpg --export-secret-keys --armor --output testexample.gpg.asc test@example.com
We would have two new files created under /tmp/gnupg
Creating NiFi flow
At this point, all set to create flow design using EncryptContentPGP and DecryptContentPGP, which use controller services StandardPGPPublicKeyService and StandardPGPPrivateKeyService
EncryptContentPGP configured with StandardPGPPublicKeyService
DecryptContentPGP with StandardPGPPrivateKeyService Note: In StandardPGPPrivateKeyService passphrase needs to be entered, which was set while running the gpg --full-generate-key command
Snapshot from working flow tested with .csv and .xlsx files
... View more
Labels:
11-06-2024
05:31 AM
Hello, you can see other solution here: https://community.cloudera.com/t5/Support-Questions/Nifi-Execute-Groovy-Script/m-p/344265#M234128
... View more
08-19-2024
07:03 AM
Hi @ckumar , I couldn't find the command, would it be in the parcels path as shown in the attached printout?
... View more
08-13-2024
05:30 PM
1 Kudo
Thanks kumar. Yeah we found that content repository file was not persistent in our container. After changing that , it works.
... View more
08-12-2024
07:54 PM
1 Kudo
Hi Ckumar, recently I can not open the UI because the error of 403 when I check the nifi-request.log file also. I think all error come from same reason.
... View more
08-09-2024
09:17 PM
thank u very much. that helped me
... View more
06-14-2024
07:46 AM
1 Kudo
@Alexy Without seeing your logs, I have no idea which NiFi classes are producing the majority of your logging. But logback is functioning exactly as you have it configured. Each time the nifi-app.log reaches 500 MB within a single day it is compressed and rolled using an incrementing number. I would suggest changing the log level for the base class "org.apache.nifi" from INFO to WARN. The bulk of all NiFi classes begin with org.apache.nifi and by changing this to WARN to you will only see ERROR and WARN level log output from the bulk of the ora.apache.nifi.<XYZ...> classes. <logger name="org.apache.nifi" level="WARN"/> Unless you have a lot of exception happening within your NiFi processor components used in your dataflow(s), this should have significant impact on the amount of nifi-app.log logging being produced. Please help our community thrive. If you found any of the suggestions/solutions provided helped you with solving your issue or answering your question, please take a moment to login and click "Accept as Solution" on one or more of them that helped. Thank you, Matt
... View more
06-10-2024
10:32 PM
@Naveen_Sagar, were you able to resolve this issue? If you were, could you please share the solution so that it can help others? If you still have concerns, could you please provide the information that @ckumar has requested?
... View more
06-06-2024
07:12 AM
@alan18080 NiFi-Registry only pushes to the GitFlowPersistenceProvider while running. NIFi-Registry will only read from Git on startup. The GitFlowPersistence Provider also only contains the flow definitions for the version controlled process groups. Each NiFi-Registry has a metadata database maintains the knowledge of which buckets exist, which versioned items belong to which buckets, as well as the version history for each item. So if you are trying to share a single Git Repo across multiple running NiFi-Registry instances this will explain why you are seeing missing versions at times across your multiple instances. Please help our community thrive. If you found any of the suggestions/solutions provided helped you with solving your issue or answering your question, please take a moment to login and click "Accept as Solution" on one or more of them that helped. Thank you, Matt
... View more