About DianaTorres

DianaTorres · ‎08-04-2025

Welcome to the Cloudera Community! To help you get the best possible solution, I have sento you a DM with further steps. Please keep us updated on your post, and we hope you find a satisfactory solution to your query.

JohnCarter · ‎08-03-2025

So I stumbled on this tool called Data Flow Manager (DFM) while working on some NiFi stuff, and… I’m kinda blown away? Been using NiFi for a few years. Love it or hate it, you know how it goes. Building flows, setting up controller services, versioning… it adds up. Honestly, never thought I’d see a way around all that. With DFM, I literally just picked the source, target, and a bit of logic. No canvas. No templates. No groovy scripting. Hit deploy, and the flow was live in under a minute.

DianaTorres · ‎07-31-2025

Here are some highlights from the month of July WEBINAR The Power of Streaming in Real-Time AI and Analytics Register Now VIRTUAL EVENT The latest innovations in data, analytics & AI Watch Now On Demand Check out the FY25 Cloudera Meetup Events Calendar for upcoming & past event details! 60 New support questions 1095 New members We would like to recognize the below community members and employees for their efforts over the last month to provide community solutions. See all our top participants at Top Solution Authors leaderboard and all the other leaderboards on our Leaderboards and Badges page. @MattWho @vats @mburgess @upadhyayk04 @Boris G @yagoaparecidoti @BobKing Share your expertise and answer some of the below open questions. Also, be sure to bookmark the unanswered question page to find additional open questions. Unanswered Community Post Components/ Labels I'm using Apache NiFi 2.x with Python-based custom processors. I have two different PythonProcessor scripts (in /python/extensions) with different logic. However, NiFi always runs only the first script's logic, even when I configure the second script in a different processor. Apache NiFi nifi-env.sh file is empty in 2.4.0. Upgrade issue in EKS Apache NiFi Error generating aggregated logs for Spark Applications on Cloudera CDP 7.2.18 Apache Spark Cloudera Data Platform (CDP) Issue with JoinEnrichment Processor Apache NiFi Issue in upgrading nifi from 2.0.0 M4 to 2.4.0 Apache NiFi

MattWho · ‎07-30-2025

@justloseit NiFi Process groups are just logical containers for processors. A Process group does not run/execute. Selecting "Start" on a process group triggers starting of all the components within that process group. In your case it sounds like you have have setup cron scheduling on your ingest/starting processor(s) within the process group. All downstream processors to that source should be set run all the time and not cron based scheduling. So what you are really looking for is how long it took the processors within that process group to process all produced FlowFiles to point of termination? Besides looking at the lineage data for each FlowFile that traverses all the processor in a process group, I can't think of how else you would get that data. Take a look at the SiteToSiteProvenanceReportingTask available in Apache NiFi. It allows you send the provenance data (produces a lot of data depending on size of yoru dataflows and amount of FlowFiles being processed) via NiFi's Site-To-Site protocol to another NiFi instance (would recommend a separate dedicated NiFi to receive this data). You can then build a dataflow to process that data how you want to retain what information you need, or send it to an external storage/processing system. Please help our community grow. 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

yagoaparecidoti · ‎07-28-2025

hi @RamaClouder, current scenario: You're running CDP in the cloud, using the CDP Public Cloud, right? if so, you have technical support included with your license. For more accurate and responsive support, we recommend opening a case in the "My Cloudera" portal as S1, and support will assist you as soon as possible. if not, please return with the stderr and stdout logs for more details. tip: Check permission settings in IAM, broker, etc.

DianaTorres · ‎07-24-2025

@Siva227 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.

lingloong · ‎07-24-2025

SELECT * FROM your_table WHERE data_dt = '__HIVE_DEFAULT_PARTITION__'; ok thank's for your reply ,i understand this example But my question is, in my Third SQL statement, using length() function in the select statement is effective and the result is 26, while in the first and second SQL , why can't this record be filtered by length in the where statement when I use the length function on the partition key? Thank You

venkatsambath · ‎07-22-2025

Hi @jonathan_l https://community.cloudera.com/t5/Community-Articles/Fully-Private-Agents-with-Cloudera-s-AI-Inference-Service/ta-p/400799 This link has an example on how to use Crew AI in Cloudera AI

DianaTorres · ‎07-17-2025

Hi @Shawn_Wang do you have any insights here? Thanks!

jkoral · ‎07-15-2025

Kshitij, Wow, that worked like a charm. When I was granting privileges to the database, I was using the following statement for all three of those including the actual password, but that did not work for me. GRANT ALL ON rman.* TO 'rman'@'%' IDENTIFIED BY 'password'; I am not really a DB person, so figured I would get the right solution from someone that is. I was going to say to keep an eye for my next posted issue regarding HDFS, but it looks like after fixing the DB issue and after restarting HDFS, we are all GREEN now!!!

Online	Offline
Last Visited	‎07-16-2026 08:36 PM

Member Since	‎11-17-2021 08:08 AM
Last Visited	‎07-16-2026 08:36 PM
Posts	1,163
Kudos received	241

Cloudera Community

Re: How to change the company in the profile

Re: Keycloak SSO Hive REST Catalog

Re: Error connecting to NiFi Registry from NiFi UI...

Re: How to change my Account Email Address?

Re: Cannot erase old /opt/cloudera/parcels

Re: How to change my company name

Re: Looking for a Tool to Simplify Apache NiFi Flo...

July 2025 Community Highlights

Re: Can we capture the run details of processor an...

Re: Datalake creation failed

Re: Frequent Node Disconnects and Flow Synchroniza...

Re: search nothing about '__HIVE_DEFAULT_PARTIT...

Re: CrewAI deployment on Cloudera AI Workbench

Re: Iceberg table compaction in CDP 7.3.1

Re: Getting access denied in MariaDB for Reports M...