Member since
09-29-2015
871
Posts
723
Kudos Received
255
Solutions
My Accepted Solutions
| Title | Views | Posted |
|---|---|---|
| 4268 | 12-03-2018 02:26 PM | |
| 3210 | 10-16-2018 01:37 PM | |
| 4316 | 10-03-2018 06:34 PM | |
| 3174 | 09-05-2018 07:44 PM | |
| 2431 | 09-05-2018 07:31 PM |
02-24-2017
01:51 PM
Can you take a thread dump and provide the output here? ./bin/nifi.sh dump /path/to/output/dump.txt
... View more
02-23-2017
08:54 PM
Also wanted to mention that site-to-site can only happen with ports on the root canvas, which is done intentionally to make it clear that it is a system decision to send or receive data out of the given instance. This means that the user that sets up the port would need write access to the root canvas, which typically in a multi-tenant environment tenants would be given to a sub-process group, but they would still need some other administrator to setup the site-to-site connection for them.
... View more
02-22-2017
10:03 PM
1 Kudo
Use expression language in PutHDFS for the value of the Directory property, so setting it to ${filename} would put each file into a directory named the same as the filename attribute of each flow file in NiFi.
... View more
02-22-2017
03:36 PM
You would need to setup an appender in logback.xml that could talk to a Splunk input. One example would be a SocketAppender to send to a TCP input in Splunk. https://github.com/bbende/jsonevent-producer/blob/master/src/main/resources/logback.xml#L8-L11
... View more
02-21-2017
06:44 PM
The message about changing the OS buffer is just a warning and not something to usually something to worry about it. What is happening is that there is a connection pool, and each time a connection is made it tries to set the socket send buffer based on the value of the property in the processor, and if it can't set it to that value than it logs a warning to let you know. The latest screenshot you posted is a completely different problem, and it is something we need to look into. What I think is happening is that the processor is holding on to flow files to transfer them in the next execution, but since you cleared the queue they are no longer valid and this is causing an unexpected situation. As Oleg mentioned, we need to see the full stacktrace from the logs for this.
... View more
02-16-2017
03:45 PM
If you set it to /tmp and set Recurse Sub Directories to true, then it will list both.
... View more
02-16-2017
03:32 PM
2 Kudos
You need to grant your users Read/Write access to the root process group (i.e. the top level canvas). You do this from the context palette on the left, using the the little policy icon.
... View more
02-15-2017
08:17 PM
1 Kudo
If you are using ${line:getDelimitedField(9,'|')} then there needs to be a flow file attribute called "line" that contains the string you want to evaluate. Does your flow extract the contents of the flow file into an attribute called "line" ? If not you could use ExtractText to do this.
... View more
02-14-2017
08:23 PM
The URL property supports expression language so that should be fine. You may want to double check that the flow files have the attributes you expect. You could have a RouteOnAttribute that routes ${latitude:isEmpty():or(longitude:isEmpty())} to somewhere so that by the time it makes it to InvokeHttp you know you have both values, or you could just use a LogAttribute and check the logs.
... View more
02-14-2017
06:55 PM
Right now you have FetchDistributedMapCache -> ExecuteScript... you could replace this with one custom processor (or maybe one custom scripted processor) that uses DistributedMapCache to fetch the questions, joins it with the response, and writes the whole thing to flow file content, thus avoiding ever sticking the questions in an attribute.
... View more