I am trying to run a merge query in PUTSQL after using ExecuteSQL to pull from source database. I then pass the results through ConvertAvrotoJSON and then to convertJSONToSQL (set to INSERT since there is no UPSERT for SQL server database). I want to now run the merge query to update if the primary key is matched or insert if not, but I have been getting all sorts of errors Input flowfile has the following attributes sql.args.1.type 12 sql.args.1.value A-001 sql.args.2.type 12 sql.args.2.value DDD sql.args.3.type 12 sql.args.3.value 2B sql.args.4.type 12 sql.args.4.value AAA sql.args.5.type 12 sql.args.5.value 2B sql.args.6.type 12 sql.args.6.value BBB sql.args.7.type 93 sql.args.7.value 1954-08-01 22:46:50.73 sql.catalog CUSDB sql.table CUSTOMERS uuid 50a3daf9-e5d8-422b-b6cb-9c92da723c55 I created the following attributes in UpdateAtributes I directed this flowfile to UpdateAttribute where I created above properties like this   sql.args.1.type = 12;  sql.args.1.value = ${vkey} sql.args.2.type = 12;  sql.args.2.value = ${AP} sql.args.3.type = 12;  sql.args.3.value = ${BP} ........ sql.args.7.type = 93;  sql.args.7.value = ${LAST_MOD_DATE} But when I check the results of the queue of the UpdateAtributes, I see that sql.args.1.type, sql.args.2.type, ... sql.args.7.type return blank values. I am doing something wrong in the way I have defined those properties? Merge query in PutSQL looks like this MERGE INTO CUSDB.dbo.CUSTOMERS as t USING (select ? as vkey, ? as ap, ? as bp, ? as lm, ? as lnum, ? as wn, ? as LAST_MOD_DATE) s ON t.EKEY = s.EKEY WHEN MATCHED THEN UPDATE SET t.ap = s.ap, t.bp = s.bp, t.lm = s.lm, t.lnum = s.lnum, t.wn = s.wn, t.LAST_MOD_DATE = s.LAST_MOD_DATE WHEN NOT MATCHED THEN INSERT (vkey, ap, bp, lm, lnum, wn, LAST_MOD_DATE) VALUES (?, ?, ?, ?, ?, ?, to_date(?, 'YYYY-MM-DD HH34:MI:SS')) I get the error that all parameters are blank. Can someone please point me in the direction to resolve this issue. Why are the attributes going blank when I set them in UpdateAttributes? ... View more

I am building a workflow to extract data from a MS SQL server table using the ExecuteSQL processor with this simple SQL: select [06 QQQ], [11 JJJ], [12 KKK], [13 JJJ], from DB_TEST.dbo.FGRID But I get the error below. routing to failure: org.apache.nifi.processor.exception.ProcessException: org.apache.avro.SchemaParseException: Illegal initial character: 06 QQQ - Caused by: org.apache.avro.SchemaParseException: Illegal initial character: 06 QQQ  Apparently, NiFi can't recognize column names with spaces and other special characters. I have tried using single and double quotes but still get same error. Question is - what can I use to reference column names with special characters. In DBeaver, I am able to query those column names with []. Any assistance will be appreciated. Thanks ... View more

  Hello All, I am new to NiFi. I have set up NiFi with LDAP authentication and NiFi starts with no issues but I don't know how to log into NiFi as "Initial Admin Identity" user "user_admin" as shown in my setup below. What should I use as the login credentials as NiFi presently rejects user_admin/<password>? nifi.properties nifi.security.user.authorizer=file-provider nifi.security.allow.anonymous.authentication=false nifi.security.user.login.identity.provider=ldap-provider   login-identity-providers.xml         <identifier>ldap-provider</identifier>         <class>org.apache.nifi.ldap.LdapProvider</class>         <property name="Authentication Strategy">START_TLS</property>           <property name="Manager DN">uid=test_admin,OU=users,DC=abc,DC=com</property>         <property name="Manager Password">*******</property>           <property name="TLS - Keystore">./conf/keystore.p12</property>         <property name="TLS - Keystore Password">*****</property>         <property name="TLS - Keystore Type">PKCS12</property>         <property name="TLS - Truststore">./conf/truststore.p12</property>         <property name="TLS - Truststore Password">******</property>         <property name="TLS - Truststore Type">PKCS12</property>         <property name="TLS - Client Auth">REQUIRED</property>         <property name="TLS - Protocol">TLS</property>         <property name="TLS - Shutdown Gracefully"></property>                  <property name="Referral Strategy">FOLLOW</property>         <property name="Connect Timeout">10 secs</property>         <property name="Read Timeout">10 secs</property>           <property name="Url">ldaps://test.com</property>         <property name="User Search Base">DC=abc,DC=net</property>         <property name="User Search Filter">sAMAccountName={0}</property>         <property name="Identity Strategy">USE_USERNAME</property>         <property name="Authentication Expiration">12 hours</property>   -----------------------   authorizer.xml     <authorizer>         <identifier>file-provider</identifier>         <class>org.apache.nifi.authorization.FileAuthorizer</class>         <property name="Authorizations File">./conf/authorizations.xml</property>         <property name="Users File">./conf/users.xml</property>         <property name="Initial Admin Identity">uid=user_admin,OU=USERS,DC=abc,DC=com</property>         <property name="Legacy Authorized Users File"></property>           <property name="Node Identity 1"></property>     </authorizer>     ... View more