Member since
01-14-2022
17
Posts
0
Kudos Received
1
Solution
My Accepted Solutions
Title | Views | Posted |
---|---|---|
586 | 02-09-2022 08:06 AM |
02-14-2022
12:14 AM
Hi, is there any chance that you can help me with this... I don't know how to pass those values to procedure Thanks
... View more
02-11-2022
09:00 AM
Hi, can You help me how to do it? Thanks in advance
... View more
02-11-2022
08:09 AM
Hi, As you can see I tried with Id instead date just to be sure that problem is not because format date, but it is not the problem. Problem is how to send those values to procedure.....
... View more
02-11-2022
08:03 AM
Hi, yes I can do this And then I get and when I call procedure it doesn't work Do I need more steps between query record and executing procedure?
... View more
02-11-2022
06:27 AM
Hi, I made some changes.... Now, I have two separate flow files (one for insert and one for delete) which works fine. And in the end I put Output port. After that job is done, I need to execute plsql procedure from destination database, so I made another process group with input port and another flow Processor generate table fetch selecting max and min date from one table like this And after that I need those two values to pass to plsql procedure and I don't know how. Query record processor look like this Last processor putsql look like this But this also doesn’t work because in last que i get two separate flow files one with min value and one with max....I think that is problem.... and I need one with two values that i can pass to plsql procedure
... View more
02-11-2022
06:03 AM
Hi, I have already tried and everything works when there are no parameters
... View more
02-11-2022
05:17 AM
Hi, I have two separate flow files (one for insert and one for delete) which works fine. And in the end i put Output port. After that job is done I need to execute plsql procedure from destination database., so I made another process group with input port and another flow Processor generate table fetch selecting max and min date from one table like this And after that I need those two values to pass to plsql procedure and I don't know how. Last processor putsql look like this and when I have no parameter to pass all works fine, but I need those parameter to pas I hope that you can help me with this. I am new in nifi as you can see
... View more
02-11-2022
12:17 AM
Hi, I am new in nifi so I don't know how to create and pass parameter with max and min value of my ID in source table to plsql procedure... Please help. My whole flow now looks like this I add another processor like this with two parameters and I pass those parametres to proseccor like this then I get error Thank you
... View more
02-11-2022
12:11 AM
Hi, can you tell me how do you create your parameters ( ${block},${txseq},${item}) in processor before this one so that you can pass them to plsqp procedure? Can you give me whole flow because this solution is not working for me now... Thank you 😄
... View more
02-10-2022
04:47 AM
Hi, can someone help me to find solution for execute plsql oracle procedure after I finish putin record in my table in database. I have flow like this and when all job is done I have to execute procedure with max and min ID from this flow... Thanks in advance
... View more
Labels:
- Labels:
-
Apache NiFi
02-09-2022
08:06 AM
Hi, thank you very very much... Delete for 3179958 records works now 6 minutes
... View more
02-08-2022
02:08 AM
Hello, I have one big table in one database that I have to sink on destination. Firs I have flow with incremental insert and it works fine. Than in other flow I have incremental delete by ID column. I am trying to delete 3179958 records from table. I have one table on source and I have to do increment delete on destination. This is my flow. I am sending every processor separate: generatetablefetch: execute sql: putdatabaserecord - delete When I have much less records it all works fine. But now flow can't finished... Is there any other solution. Thanks in advance
... View more
- Tags:
- NiFi
- optimization
Labels:
- Labels:
-
Apache NiFi
01-14-2022
07:06 AM
Thank you for everything. I try this and nifi doesn't crashes. Processor GenerateTableFetch finish work very quick, but insert into database (processor PutDatabaseRecod) is very slow. Can the process be somehow speeded up? I'm sending picture of my flow Thank's in advance
... View more
01-14-2022
05:34 AM
Thank you very very much. My nifi crashes on insert (processor PutDatabaseRecord). Now I will try set these values Max Rows Per Flow File" & "Output Batch Size" & Fetch Size and try again. If it works I let You know. Thank's again
... View more
01-14-2022
05:06 AM
Than you I will try this. I'm new in nifi, so I make flow like this So, I need GenerateTableFetch processor before QueryDatabaseTable? Am I right?
... View more
01-14-2022
04:09 AM
Hello, I need to move one big table (16 GB) from one oracle database to another. When I try to move table with more then 1 GB data, my nifi GUI crashes. Can you suggest me how to do it? Thanks' in advance Lejla
... View more
Labels:
- Labels:
-
Apache NiFi