Support Questions
Find answers, ask questions, and share your expertise

Value error using Apache Nifi HBASE lookup

New Contributor

Hi,

We are evaluating apache Nifi for our realtime data needs.

I created Nifi flow, which is consuming json data from kafka and the results are being sent to another kafka topic after enrichment.

Problem: HbaseLookupService is using for enrichment. But the returned data is not expected value.

I am sharing the output of my flow. We want to see value of "hbase_integid" as "123456789", but lookup service returns

"MapRecord[{SERIAL_NUM=123456789}]",

How can we extract only value of SERIAL_NUM value ("123456789")??

[ {
"table" : "SIEBEL.S_ASSET",
"op" : "Update",
"hbase_integid" : "MapRecord[{SERIAL_NUM=123456789}]",
"op_type" : "U",
"op_ts" : "2018-04-02 05:48:35.055299",
"current_ts" : "2018-04-02T08:48:40.071000",
"pos" : "00000000020530642196",
"before" : {
"ROW_ID" : "1-G7B7EGF",
"BILLACCT_ID" : null,
"BILL_ACCNT_ID" : "1-G79GNWP",
"BILL_PROFILE_ID" : "1-1FJHFB0",
"INTEGRATION_ID" : "1-G79GU5K",
"NAME" : null,
"OWNER_ACCNT_ID" : "1-G79GEVV",
"OWNER_CON_ID" : "1-G79GEW3",
"PROD_ID" : "1-Q5B470",
"PROMOTION_ID" : null,
"PROM_INTEG_ID" : null,
"PROM_ITEM_ID" : null,
"PR_ACCNT_ID" : null,
"PR_CON_ID" : "No Match Row Id",
"ROOT_ASSET_ID" : "1-G7B7EFI",
"SERIAL_NUM" : null,
"X_VF_MSISDN" : null,
"X_VF_PERMISSONS" : null
},
"after" : {
"ROW_ID" : "1-G7B7EGF",
"BILLACCT_ID" : null,
"BILL_ACCNT_ID" : null,
"BILL_PROFILE_ID" : null,
"INTEGRATION_ID" : null,
"NAME" : null,
"OWNER_ACCNT_ID" : null,
"OWNER_CON_ID" : null,
"PROD_ID" : null,
"PROMOTION_ID" : null,
"PROM_INTEG_ID" : null,
"PROM_ITEM_ID" : null,
"PR_ACCNT_ID" : null,
"PR_CON_ID" : null,
"ROOT_ASSET_ID" : null,
"SERIAL_NUM" : null,
"X_VF_MSISDN" : null,
"X_VF_PERMISSONS" : null
}
} ]

Thanks

1 REPLY 1

New Contributor

@ahadjidj

Hi Abdelkrim,

I read your following post and I tried to do same steps.

https://community.hortonworks.com/articles/138632/data-flow-enrichment-with-nifi-lookuprecord-proces...

do you have any idea about my issue?

Thanks

; ;