Support Questions
Find answers, ask questions, and share your expertise
Announcements
Alert: Welcome to the Unified Cloudera Community. Former HCC members be sure to read and learn how to activate your account here.

Value error using Apache Nifi HBASE lookup

Highlighted

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

Re: Value error using Apache Nifi HBASE lookup

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

Don't have an account?
Coming from Hortonworks? Activate your account here