Member since
01-19-2020
5
Posts
0
Kudos Received
0
Solutions
04-27-2020
09:37 PM
'm trying to modify big JSON file with more than 10K records. I have this kind of input and I need to make jolt transformation for each record : [
{
"id": 1031435,
"event_id": "Formula_257",
"formula_id": 257,
"ts_start": 1583164200084000,
"ts_end": 1583164484960000,
"type": "formula",
"details": {
"6aa0734f-6d6a-4b95-8a2b-2dde346f9df7": {
"PowerActiveTriPhase": 183836912
}
},
"ack_ts": null,
"ack_user": null
},
{
"id": 1031435,
"event_id": "Formula_257",
"formula_id": 257,
"ts_start": 1583164200084000,
"ts_end": 1583164484960000,
"type": "formula",
"details": {
"6aa0734f-6d6a-4b95-8a2b-2dde346f9df7": {
"PowerActiveTriPhase": 183836912
}
},
"ack_ts": null,
"ack_user": null
}
] This is my spec: [ { "operation": "shift", "spec": { "id": "id", "event_id": "event_id", "formula_id": "formula_id", "ts_start": "ts_start", "ts_end": "ts_end", "type": "type", "details": { "": { "$": "equipment_id", "": { "$": "parameter", "@": "value" } } }, "ack_ts": "ack_ts", "ack_user": "ack_user" } } ] It works for one record but doesn't work for >1 record and im getting null in output. How to fix it? @Shu_ashu @mburgess Thanks!
... View more
Labels:
- Labels:
-
Apache NiFi
02-17-2020
01:14 AM
Good day,
I'm trying to upload nifi template and getting this kind of error:
org.apache.nifi.processors.kite.ConvertAvroSchema is not known to this NiFi instance
I suppose that my Nifi Instance misses some component - but where can I get it and where on file system I need to add missing file?
I'm little bit confused.
Thanks!
... View more
Labels:
- Labels:
-
Apache NiFi
01-23-2020
02:32 AM
I'm afraid it doesn't help as well 😞 I suppose what problem is in configuration in hadoop environment - I will try ones again on new linux server with clean installation Thanks a lot!
... View more