About Althotta

Althotta · ‎09-29-2025

i have a JSON payload which contains latest and old orders. The data should be compared and output New, update, deleted. How can do it do that in NIFI?. "latest_orders": [ { "order_id": "1001", "customer": "Alice", "amount": 250 }, { "order_id": "1002", "customer": "Bob", "amount": 300 }, { "order_id": "1004", "customer": "Diana", "amount": 150 } ], "old_orders": [ { "order_id": "1001", "customer": "Alice", "amount": 200 }, { "order_id": "1002", "customer": "Bob", "amount": 300 }, { "order_id": "1003", "customer": "Charlie", "amount": 400 } ] } Output: { "order_id": "1001", "customer": "Alice", "amount": 250, "Action":"UPDATE" }, { "order_id": "1002", "customer": "Bob", "amount": 300 ,"Action":"UPDATE"}, { "order_id": "1004", "customer": "Diana", "amount": 150,"Action":"NEW" }, { "order_id": "1003", "customer": "Charlie", "amount": 400,"Action":"DELETE" }

Althotta · ‎03-03-2025

@wcbdata , @HorizonNet Does it support one Git and multiple NIFI registry?. We have a 2 nifi registries one in PROD and other in DEV Zone. Commit from either directions.

Althotta · ‎07-31-2024

Has this been resolved. We are also facing similar issue.

Althotta · ‎01-31-2024

Hi @Dan Burkert , i have tried exactly the same DDL and it give the error. I used hue/impala to create the table. Can you help? ParseException: Syntax error in line 4:undefined: RANGE(year, month) ( ^ Encountered: RANGE Expected: CACHED, COMMENT, LOCATION, PARTITION, PARTITIONED, PRODUCED, ROW, SORT, STORED, TBLPROPERTIES, UNCACHED, WITH CAUSED BY: Exception: Syntax error

Althotta · ‎08-29-2023

Having the same issue while loading data from NIFI 1.21 to Kudu. Anyone find the solution?. I can connect to Kudu Via Hue and Impala

Althotta · ‎05-08-2023

i have slightly modifed the spec as. The matchingStatus_value doesn't provide the right result [{ "operation": "shift", "spec": { "header": { "timeStamp": "records.inv_activity_ts", "activityId": "records.inv_activity_id", "action": "records.action" }, "resource": { "drniId": "records.inv_id", "subtype": "records.inv_subtype", "name": "records.inv_name", "resourceCharacteristic": { "*": { "name": { "tmf639_dataSource_ingestion_uuid": { "@(2,value)": "records.tmf639_dataSource_ingestion_uuid" }, "createdDate": { "@(2,value)": "records.createdDate" }, "lastModifiedDate": { "@(2,value)": "records.lastModifiedDate" }, "status": { "@(2,value)": "records.status" } } } } } } }] Is this a valid one?

Althotta · ‎05-08-2023

For the below given input, how do i move the name value pairs(installDate and status) to the upper level { "header": { "version": "1.0", "timeStamp": "1670484663189", "activityId": "256388257993155783", "action": "create", "refreshId": "null" }, "resource": { "drniId": "256383859946641699", "@type": "LogicalCrossConnection", "subtype": "Backplane Connection", "name": "Backplane Connection", "resourceCharacteristic": [ { "name": "tmf639_dataSource_ingestion_uuid", "value": "256383859946641699", "@type": "string" }, { "name": "p16Latest", "value": true, "@type": "boolean" }, { "name": "installDate", "value": "202303323", "@type": "string" }, { "name": "status", "value": "In Service", "@type": "string" } ], "resourceRelationship": [ { "drniId": "256387639517862117", "@type": "LogicalInterface:HAS_CONNECTION_COMPONENT:OUT", "subtype": "ODU2e", "name": "ODU2e.1-8", "relationDrniId": "256383859946641700", "resourceRelationshipCharacteristic": [ { "name": "p16Latest", "value": true, "@type": "boolean" }, { "name": "sectionNumber", "value": 0, "@type": "long" }, { "name": "p3CreateActivity", "value": 256388257993155780, "@type": "long" }, { "name": "isNotInRoute", "value": "N", "@type": "string" }, { "name": "p2Create", "value": 1670480203578, "@type": "long" }, { "name": "seq", "value": 1, "@type": "long" } ] }, { "drniId": "256383859946641335", "@type": "LogicalInterface:HAS_CONNECTION_COMPONENT:OUT", "subtype": "ODU2e", "name": "ODU2e.1-8", "relationDrniId": "256383859946641701", "resourceRelationshipCharacteristic": [ { "name": "p16Latest", "value": true, "@type": "boolean" }, { "name": "sectionNumber", "value": 0, "@type": "long" }, { "name": "p3CreateActivity", "value": 256388257993155780, "@type": "long" }, { "name": "isNotInRoute", "value": "N", "@type": "string" }, { "name": "latest", "value": [ 2, 3, 16 ], "@type": "array" } ] } ] } } Expected Output { "records" : { "inv_activity_ts" : "1670484663189", "inv_activity_id" : "256388257993155783", "action" : "create", "inv_id" : "256383859946641699", "inv_subtype" : "Backplane Connection", "inv_name" : "Backplane Connection", "installDate" : "202303323", "status" : "status" } } @SAMSAL Any help you could provide?

Althotta · ‎05-08-2023

I have used the below spec for moving some of the resource characterstic to top level but iam getting null values. [ { "operation": "shift", "spec": { "header": { "timeStamp": "records.inv_activity_ts", "activityId": "records.inv_activity_id", "action": "records.action" }, "resource": { "drniId": "records.inv_id", "subtype": "records.inv_subtype", "name": "records.inv_name", "resourceCharacteristic": { "*": { "name": { "matchingkey": "records.matchingkey-value", "status": "records.status-value" }, "value": { "matchingkey": "records.matchingkey-value", "status": "records.status-value" } } } } } } ] Output iam getting { "records" : { "inv_activity_ts" : "1670484663189", "inv_activity_id" : "256388257993155783", "action" : "create", "inv_id" : "256383859946641699", "inv_subtype" : "Backplane Connection", "inv_name" : "Backplane Connection", "matchingkey-value" : null, "status-value" : null } } What is mistake iam making?.

Althotta · ‎05-02-2023

Thanks @SAMSAL You are a genius. I was caught with the duplicate index array and couldn't resolve.

Althotta · ‎05-01-2023

Basically inhertied properties of header and resource inside resourceRelationshipCharacteristic { "records" : [ { "relationDrniId" : "5143209344417655493", "timeStamp" : "1681441547144", "activityId" : "5142917973836294867", "action" : "modify", "name": "p3Latest", "value": true, "@type": "boolean" }, { "relationDrniId" : "5143209344417655493", "timeStamp" : "1681441547144", "activityId" : "5142917973836294867", "action" : "modify", "name": "isNotInRoute", "value": "N", "@type": "string" } , { "relationDrniId" : "5143209344417655494", "timeStamp" : "1681441547144", "activityId" : "5142917973836294867", "action" : "modify", "name": "p3Latest", "value": true, "@type": "boolean" } , "relationDrniId" : "5143209344417655494", "timeStamp" : "1681441547144", "activityId" : "5142917973836294867", "action" : "modify", "name": "isNotInRoute", "value": "N", "@type": "string" } ] }

Online	Offline
Last Visited	‎10-14-2025 08:20 PM

Member Since	‎02-11-2021 02:26 AM
Last Visited	‎10-14-2025 08:20 PM
Posts	33
Kudos received	5

Cloudera Community

Compare data within the JSON using NIFI

Re: Configuring the Git Persistence Provider for t...

Re: NiFi Nodes getting disconnected frequently

Re: Creating dynamic range partition in kudu

Re: [Kerberos ][Cloudera manager 7] Unable to crea...

Re: JOLT Transformation: Moving Child name value t...

JOLT Transformation: Moving Child name value to pa...

Re: Jolt transformation Array to Flatten

Re: Jolt transformation Array to Flatten

Re: Jolt transformation Array to Flatten