Hi Team,  Am getting error on JoinEnrichment and don't know why it is coming, Please suggest. My query in JoinEnrichment : SELECT original.*, enrichment.* FROM original FULL JOIN enrichment ON original.name = enrichment.name Error receiving JoinEnrichment[id=a17b1f06-f80c-3641-945f-c2ff331f8028] Failed to join 'original' FlowFile FlowFile[filename=cmdbci-mtaas] and 'enrichment' FlowFile FlowFile[filename=cmdbci-mtaas]; routing to failure: java.sql.SQLException: Error while preparing statement [SELECT original., enrichment. FROM original FULL JOIN enrichment ON original.name = enrichment.name] Caused by: org.apache.calcite.runtime.CalciteContextException: From line 4, column 4 to line 4, column 34: Cannot apply '=' to arguments of type '<JAVATYPE(CLASS JAVA.LANG.OBJECT)> = <JAVATYPE(CLASS JAVA.LANG.STRING)>'. Supported form(s): '<COMPARABLE_TYPE> = <COMPARABLE_TYPE>' Caused by: : Corg.apache.calcite.sql.validate.SqlValidatorExceptionannot apply '=' to arguments of type '<JAVATYPE(CLASS JAVA.LANG.OBJECT)> = <JAVATYPE(CLASS JAVA.LANG.STRING)>'. Supported form(s): '<COMPARABLE_TYPE> = <COMPARABLE_TYPE>' Sample input from Original Location,Environment,ip_address,category,name,dv_sys_updated_on "",,,Hardware,Ndiggan,2022-12-17 22:37:28 "",,,Hardware,class,2022-12-31 22:37:38 "",,,,Vlan2,2022-12-27 02:17:13 Sample input from Enrichment Location,Environment,ip_address,category,name,dv_sys_updated_on "",,,Hardware,vpna,2022-12-17 22:36:02 "",,,Hardware,dlcccno,2022-12-17 22:37:04 "",,,Hardware,Ndiggan,2022-12-17 22:37:28  ... View more

I have a scenario where am triggering API in batches (1000 records in each). from the first API I get the value of total records in attribute list X-Total-Count, i wants to merge them all. Please let me know how i can leverage the wait processor in it to wait until we get the whole data till value of X-Total-Count.   Wait Processor properties, i have configured.  ... View more

Hi, I have a use, where i need to upload the processor group (.json) file from the curl / API. Please suggest.  OR can we do this operation in NiFi CLI without using NiFi registry.  ... View more

Hi Everyone,    I have a use case, where i need to generate timestamp in Epoch UTC format till seconds 1662371646, and perform Substract operation for generate one minute ago time in same format.  below is my Jolt Spec :   [ { "operation": "default", "spec": { "currenttime": "${now():toNumber()}" } }, { "operation": "modify-overwrite-beta", "spec": { "timeOneMinu": "=Subtract(@(1,currenttime),60)" } } ]   Output :    { "currenttime": "1662372281", "timeOneMinu": "1662372221" }   Please suggest, How we can do this.  ... View more

I have a use case where I have couple of key values and perform if-else operation on it. If condition is not matched then whole content will drop, else pass the content as a result.   Input json: { "id": 30006, "SourceName": "network", "Number": 1, "SourceNameCopy": "network", "currenttime": "Thu Aug 30 21:19:27 IST 2022" } My Jolt Spec: [ { "operation": "shift", "spec": { "SourceNameCopy": { "network": { "@1": "&2", "#id": "id", "#SourceName": "SourceName", "#Number": "Number", "#currenttime": "currenttime" }, "hardware": { "@1": "&2", "#id": "id", "#SourceName": "SourceName", "#Number": "Number", "#currenttime": "currenttime" } } } } ] Expected output if condition matched : { "id": 30006, "SourceName": "network", "Number": 1, "SourceNameCopy": "network", "currenttime": "Thu Aug 30 21:19:27 IST 2022" } Else (condition not matched) Drop the whole event as null. Problem Statement : The Key values is getting as a string, it should contain actual value in output as a result. ... View more