Member since
07-30-2019
898
Posts
195
Kudos Received
91
Solutions
My Accepted Solutions
Title | Views | Posted |
---|---|---|
703 | 10-05-2021 01:53 PM | |
12928 | 09-23-2019 06:03 AM | |
4834 | 05-04-2019 08:42 PM | |
912 | 06-11-2018 12:45 PM | |
8942 | 06-04-2018 01:11 PM |
08-21-2017
04:40 PM
@dhieru singh Did you clear all of the zero byte files from queue on the connection first?
... View more
08-21-2017
04:29 PM
@dhieru singh
I was able to replicate the error when I tried to write 0 byte files. Use the GenerateFlowFile processor to create ten 100 byte files, instead of zero byte files
... View more
08-21-2017
04:17 PM
@sally sally In this question, I provided an example of a script that will stop a processor. Stop a processor with a script Won't this work for you?
... View more
08-21-2017
03:29 PM
1 Kudo
@Alvin Jin May I understand the Volatile Content Repository only keeps the content for the flowfiles running in the flow? Once the flowfiles are finished, the contents are wipe out from memory, and can't be found in Repository. --- Correct In contrast, the disk-based volatile content repository will keep the contents for flowfiles even out of the flow, based on the retention setting. -- The File System Content Repository archives flow files after they are dropped from the flow based on the two archive properties nifi.content.repository.archive.max.retention.period and nifi.content.repository.archive.max.usage.percentage
... View more
08-20-2017
08:41 PM
@dhieru singh Try putting the actual host name instead of localhost for the Kafka Broker property.
... View more
08-20-2017
08:35 PM
@sally sally
The Wait processor works with the Notify processor. The configuration of the Wait processor: Here is the configuration of the Notify processor that will be a trigger for the Wait processor: Here are the DistributedMapCacheClientService and DistributedMapCacheServer controller services being used by these processors and their configurations. DistributedMapCacheServer DistributedMapCacheClientService It is better to put the actual hostname instead of just localhost. The DistributedMapCacheClientService controller service needs to have a DistributedMapCacheServer controller service configured. Replace the PutDistributedMapCache processor with the Notify processor in your flow.
... View more
08-20-2017
08:11 PM
@dhieru singh So, there is a Kafka Broker running on the same system as NiFi? Is this an HDF cluster? Is 9092 the correct port?
... View more
08-19-2017
08:54 PM
@Alvin Jin I didn't mean to confuse you. It does auto clean up. So, as files complete their path in the flow, the flow files will be removed from the flow. Thus, freeing up space for new flow files.
... View more