Thanks for the explanation, @dmorvant .   From what you described, it seems to me that the ideal solution for this would be to use NiFi Parameters. You could have 3 different Parameter Contexts, each of them with a different value for database.name.   Each one of the 3 Process Groups would use one of the Parameter Contexts. Then, when you create your DBCPConnectionPool controller service, you can specifyy the Database Connection URL parameter as, for example:    jdbc:postgresql://cdp.100.20.115.239.nip.io:5432/#{database.name}   With this, the controller service of each Process Group would connect to the database defined in the Parameter Context of that group. You don't even need a DBCPConnectionPoolLookup in this case.   Would that address you need? What the NiFi version that you are using?   André -- Was your question answered? Please take some time to click on "Accept as Solution" below this post. If you find a reply useful, say thanks by clicking on the thumbs up button. ... View more

@AzfarB ,   Which other roles are running on the same node as this Solr role? Could you provide the output of a "sar -r 5 12" command?   Cheers, André   ... View more

@pandu2022 ,   Have you updated the properties below for *all* the Impala service roles (ID, catalog and statestore)?   principal: When using a load-balancer this should be of the form impala_test/<LB_fqdn>@<REALM>. If not using a LB, this should be impala_test/<host_fqdn>@<REALM>. be_principal: This is only necessary when a LB is being used and should be of the form impala_test/<host_fqdn>@<REALM>.   Cheers, André -- Was your question answered? Please take some time to click on "Accept as Solution" below this post. If you find a reply useful, say thanks by clicking on the thumbs up button. ... View more

@pandu2022 ,   Understood. Just keep in mind that not knowing any details makes it more difficult to help. What's your Kerberos KDC? (AD, MIT, FreeIPA, or other) When you changed the Impala principal name, did you create the new principal in Kerberos? You need to make sure that all the principals "impala_test/<host>" exist in the KDC for all the hosts. Did you regenerate the keytabs for all the Impala Daemons, Catalog and State Store with the new principal name? Cheers, André -- Was your question answered? Please take some time to click on "Accept as Solution" below this post. If you find a reply useful, say thanks by clicking on the thumbs up button. ... View more

Hi @dmorvant ,   The QueryDatabaseTableRecord processor is probably not the processor that you need. The main objective of this processor it to periodically query the same table looking for recent records added to the table that need to be ingested. Rather than triggered by an incoming flowfile, this processor is typically scheduled to run at regular intervals.   It's also a stateful processor, which records the last record seen in the configured table. If you were able to change the configured database where it was looking for the table, it could confuse the processor and generate unexpected results.   I believe that the processor that you're looking for is the ExecuteSQLRecord. This processor receives a flowfile with a SQL query and executes the query against the configured DBCP. If using DBCPConnectionPoolLookup, you can add a "database.name" attribute to the incoming flowfile to do what you want.   If this is not what you need, it would help to understand what's your end goal so that we can thing of other ways to do what you need.   Cheers, André -- Was your question answered? Please take some time to click on "Accept as Solution" below this post. If you find a reply useful, say thanks by clicking on the thumbs up button. ... View more

Did you change this configuration in Cloudera Manager? Can you share screenshots of your configuration?   André ... View more

@Katja ,   I'm not totally sure but it may be possible that bind variables are accepted inside WITH clauses. Would you be able to try the alternative below? With variable1 as ( SELECT orders.order_id, orders.order_date FROM quest_stage.orders orders ) Select * from variable1 WHERE order_date = (CAST(? AS TIMESTAMP))   Cheers, André -- Was your question answered? Please take some time to click on "Accept as Solution" below this post. If you find a reply useful, say thanks by clicking on the thumbs up button. ... View more

@asomrak ,   Please have a look at the individual nodes and look for a directory called /tmp/scm_prepare_node.* Inside that directory there should be a log file called scm_prepare_node.log, which could tell you more about the error.   If you can't figure out the root cause from that log's content, please share the file here so that we can take a look.   Cheers, André -- Was your question answered? Please take some time to click on "Accept as Solution" below this post. If you find a reply useful, say thanks by clicking on the thumbs up button. ... View more

@Tra ,   Could you please explains what your configuration is and which steps you executed to get to this point?   Cheers, André   ... View more