Member since
02-01-2022
270
Posts
96
Kudos Received
59
Solutions
My Accepted Solutions
Title | Views | Posted |
---|---|---|
2051 | 06-12-2024 06:43 AM | |
2940 | 04-12-2024 06:05 AM | |
2082 | 12-07-2023 04:50 AM | |
1240 | 12-05-2023 06:22 AM | |
2157 | 11-28-2023 10:54 AM |
02-26-2024
08:27 AM
3 Kudos
@krishna123 @jameswookyz @rafy NiFi processor are configured with a Run Schedule, by default processors are configured with a Run Schedule of 0 secs. This tells NiFi core to schedule this processor to execute as often as possible. The Scheduling part of the processor handles checking if any of the inbound connections to the processor with queued data or last execution resulted in data. If there is no inbound queued FlowFiles, the NiFi controller will yield the processor scheduling. This yielding is designed to prevent the processor from just constantly trying to schedule when there is no work to do. If there is work to do, the processor will get scheduled to execute. The scheduling typically consumes microseconds of CPU time. And the built-in yielding prevents excessive cpu usage when no work exists to execute upon. Adjusting the run schedule does not change behavior of yielding, but when flow is constant for periods of time, changing the run schedule alters the throughput performance. Hope this clarifies things. If you found any of the suggestions/solutions provided helped you with your issue, please take a moment to login and click "Accept as Solution" on one or more of them that helped. Thank you, Matt
... View more
01-31-2024
02:21 AM
1 Kudo
Upon examination, implementing the queue as a First In First Out prioritizer and configuring the load balancing strategy to Partition by attribute with the kafka.partition attribute has proven effective in maintaining the order.
... View more
01-26-2024
11:27 AM
@ZorteK 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
01-18-2024
05:39 AM
@Alfies Thanks for posting. I cant see anything that jumps as far as why this would not work in 1.21. I would wonder if it works in 1.24. If it does, then for sure that compatiblity was added since 1.21. If you are required to use 1.21, i would recommend opening a Jira to report the bug you are describing.
... View more
01-17-2024
10:21 PM
@EbieCAS, Did the response assist in resolving your query? If it did, kindly mark the relevant reply as the solution, as it will aid others in locating the answer more easily in the future.
... View more
01-16-2024
03:11 AM
Ofcourse we can help. Just make a new post. Try to include as much detail as possible, screenshots, how you have invokeHttp configured, errors, etc. In your new post tag me using the @ with my username "steven-matison".
... View more
01-14-2024
02:52 AM
1 Kudo
HI @steven-matison , I have added monitor activity processor for this scenario and working fine. The first table load success queue connected to monitor activity processor, once load completed, the inactive message connected to second table... then second table execution starts after the getting the inactive message from monitor activity processor Thanks.
... View more
01-03-2024
06:50 AM
@enam I cant see the entire configuration of the second InvokeHTTP so I am not sure if you are passing those new attributes into the HTTP URL. If you are not doing that, I think the solution you are looking for is to have the AttributesToJson set Destination to FlowFile Content. Then when you post that to invokeHttp, those values are seen as the post content.
... View more
12-11-2023
07:52 AM
@SAMSAL Thank you. For future reference. If you ever need to figure out what the request is, simply use NIFI UI to do the action you want while monitoring your Developer Tools. This will expose the full request/response on any given UI action. I have filed a JIRA for this. https://issues.apache.org/jira/browse/NIFI-12503
... View more
12-08-2023
02:05 AM
@raj_dev 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.
... View more