Member since
06-08-2022
3
Posts
0
Kudos Received
0
Solutions
06-12-2022
06:43 PM
@MattWho Hi Matt, my incoming flowfile is basically a folder that contains another folder that contains a .json.jz file (folder->another_folder->file.json.gz), CompressContent processor is meant for .gz incoming file.. How to recursively decompress so it decompresses the .json.jz that is part of the subfolder? or how to unpack the first folder without touching subfolders/files?
... View more
06-09-2022
03:24 AM
the InvokeHTTP response: from the queue list: after I download: Now I have a flow file in the nonzero status queue from ExecuteStreamCommand as follows the whole cycle:
... View more
06-08-2022
07:35 PM
I receive a response from InvokeHTTP as a folder->another_folder->file.json.gz and I want to do some operations on the json file using SplitJson processor, so, I need to decompress the file.json.gz I tried to UpdateAttribute to rename the parent folder to be folder.zip then UnpackContent but it's not supporting .gz format Then, I tried instead of UnpackContent, the ExecuteStreamCommand with unzip command with a plan to use PutFile then ListFile to get the file.json.gz and pass to SplitJson but I got this error in ExecuteStreamCommand step Failed to write flow file to stdin due to Broken pipe: java.io.IOException: Broken pipe What's the solution for this? I tried to set Connection Timeout propriety to 120s but still the same error, What is the best way to get file.json.gz, decompress it and pass it to SplitJson processor?
... View more
Labels:
- Labels:
-
Apache NiFi
-
NiFi Registry