Member since
07-30-2019
920
Posts
195
Kudos Received
91
Solutions
My Accepted Solutions
Title | Views | Posted |
---|---|---|
1029 | 10-05-2021 01:53 PM | |
14419 | 09-23-2019 06:03 AM | |
5592 | 05-04-2019 08:42 PM | |
1139 | 06-11-2018 12:45 PM | |
10411 | 06-04-2018 01:11 PM |
06-06-2018
02:58 PM
@Jason Sphar What version of windows is being used?
... View more
06-04-2018
01:11 PM
@dhieru singh Try setting the demarcator on the Consume processor.
... View more
06-03-2018
05:14 PM
@dhieru singh What is the values of the property "Message Demarcator"?
... View more
06-02-2018
08:53 PM
@Zedric Cruz I'm assuming when you say network issue, you mean intermittent connectivity. 1. There will not be data loss. One of the fundamental designs of NiFi is to not have data loss in the event of failures or errors. 2. Data queued on a failed node will remain on that node until it is brought back online. 3. There are multiple ways to move data from one node to another. Post/Listen HTTP is one example. But, I'm assuming the node you want to move the data from is online and NiFi is up. 4. If the PutSFTP doesn't successfully send the data to the SFTP server, then the session will fail and be retried, depending on the configuration of the flow. But, the data will not be lost, unless the PutSFTP processor is configured to terminate files that go through the failure relationship. There are many ways to design the flow to automatically handle issues that may occur. If I made any incorrect assumptions about your questions, please clarify and I can provide a more complete answer.
... View more
05-15-2018
05:06 PM
@David Sandoval That is great to hear. Would you do me a favor and accept my answer?
... View more
05-15-2018
04:41 PM
1 Kudo
@David Sandoval The property Topic Name must match what you used in the PublishKafka processor, in this case "tweets". So, change the Topic Name(s) to tweets in the ConsumeKafka processor. FYI, when responding to a comment or an answer posted, it is best to post the response in the same answer or comment.
... View more
05-15-2018
03:32 PM
@David Sandoval Would you post a snapshot of the ConsumeKafka processor?
... View more
05-15-2018
02:38 PM
@David Sandoval It looks like a version compatibility issue. Delete that property from the processor. Does that cause another issue? What version of NiFi are you using?
... View more
05-15-2018
01:18 PM
@David Sandoval
Will you provide a snapshot of the processor configuration? What version of HDF are you using?
... View more
05-10-2018
09:14 PM
@Mark Kotlyar Make sure the nifi user has access down the entire path of the file. Easy way to be sure, is to sudo as the nifi user and then see if you are able to access the file. Ambari is in various stages of maturity. Some things are good to go, others are still being worked.
... View more