Member since
04-11-2016
471
Posts
325
Kudos Received
118
Solutions
My Accepted Solutions
Title | Views | Posted |
---|---|---|
2077 | 03-09-2018 05:31 PM | |
2647 | 03-07-2018 09:45 AM | |
2537 | 03-07-2018 09:31 AM | |
4406 | 03-03-2018 01:37 PM | |
2474 | 10-17-2017 02:15 PM |
06-02-2016
09:12 PM
Hi @Thierry Vernhet, I just had a look and I believe this is because the property "Rolling filename pattern" is not set. In such case, the processor does not detect the file has changed and it does not reset its state. I have raised a JIRA to track this issue to improve things in such a situation: https://issues.apache.org/jira/browse/NIFI-1959
... View more
06-01-2016
08:31 AM
1 Kudo
Hi @Manikandan Durairaj, Hive and ORC support in NiFi is a work in progress: https://issues.apache.org/jira/browse/NIFI-1886 https://issues.apache.org/jira/browse/NIFI-1663 https://issues.apache.org/jira/browse/NIFI-981 It will probably be available in the next version of NiFi 0.7.0 Hope this helps.
... View more
05-31-2016
07:48 AM
1 Kudo
core-site and hdfs-site contain information regarding IP addresses to use to connect your cluster. Depending of what is in your configuration files, your NiFi instance may not be able to reach HDFS.
... View more
05-31-2016
06:59 AM
Looking at: java.nio.channels.UnresolvedAddressException: null at sun.nio.ch.Net.checkAddress(Unknown Source) ~[na:1.8.0_91] at sun.nio.ch.SocketChannelImpl.connect(Unknown Source) ~[na:1.8.0_91] at I'd say that there is a network issue between your NiFi instance and your HDFS cluster. Did you correctly configure the processor with IP addresses and ports? Are you sure it is reachable from your NiFi instance?
... View more
05-31-2016
06:17 AM
1 Kudo
Be careful: swap is not for flow files, it is for flow files attributes (it is not flow files content). Flow files content is written in the content repository, have a look here: https://nifi.apache.org/docs/nifi-docs/html/overview.html#nifi-architecture. Regarding swap, it depends of the implementation, but the default is to swap in the Flow File repository.
... View more
05-30-2016
02:14 PM
When you have a connection between two processors, you can right-click on it to configure it. Then, in settings tab, you can configure back pressure: https://nifi.apache.org/docs/nifi-docs/html/user-guide.html#settings
... View more
05-30-2016
01:50 PM
Swap is just about information stored in JVM memory. Flow files will be stored in the queue as long as you have available space on disks. However you may want to have a look at back pressure features: You can apply backpressure on a specific connection, it will cause the processor that is the source of the connection to stop being scheduled to run until the queue clears out. However data will still queue up in that processor's incoming connections. So to force backpressure to propagate all the way back to the source, you would need to configure each of the connections in the flow to have backpressure applied.
... View more
05-30-2016
01:29 PM
1 Kudo
Hi @viswanatha reddy, If I am not mistaken, this property means that attributes linked to the related flow files will be swapped to disk instead of keeping the information in memory. In this case, it happens when there are more than queued 20000 flow files. Hope this helps.
... View more
05-27-2016
08:22 AM
1 Kudo
Hi @Thierry Vernhet, To achieve what you are looking for, I believe you must set the property "Enable DOTALL mode" to true. Below is a template that produces the expected result with the example you gave. extracttextall.xml Hope this helps.
... View more