You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@nifi.apache.org by PEETERS Philippe <ph...@etnic.be> on 2018/11/12 10:36:12 UTC
Issue with GeoEnrichIP in NiFi 1.8.0
Hello,
I've installed Nifi 1.8.0 and import the processes developed and running with nifi 1.7.1. It looks like the GeoEnrichIP doesn't work correctly anymore in 1.8.0.
To be sure I've done a clean install of 1.8.0 and defined a simple process:
GenerateFlowFile -> GeoEnrichIP -> LogAttribute
using the same maxmind database used in 1.7.1 : GeoLite2-City.mmdb
Any match generates an exception:
2018-11-12 11:23:57,817 ERROR [Timer-Driven Process Thread-2] org.apache.nifi.pr
ocessors.GeoEnrichIP GeoEnrichIP[id=0730375f-0167-1000-7c0a-6ae0f575136a] GeoEnr
ichIP[id=0730375f-0167-1000-7c0a-6ae0f575136a] failed to process session due to
java.lang.UnsupportedOperationException; Processor Administratively Yielded for 1 sec: java.lang.UnsupportedOperationException
java.lang.UnsupportedOperationException: null
at java.util.Collections$UnmodifiableMap.put(Collections.java:1457)
at com.fasterxml.jackson.databind.node.ObjectNode.set(ObjectNode.java:370)
at org.apache.nifi.processors.maxmind.DatabaseReader.get(DatabaseReader.java:174)
at org.apache.nifi.processors.maxmind.DatabaseReader.city(DatabaseReader.java:211)
at org.apache.nifi.processors.GeoEnrichIP.onTrigger(GeoEnrichIP.java:103)
at org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27)
at org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1165)
at org.apache.nifi.controller.tasks.ConnectableTask.invoke(ConnectableTask.java:203)
at org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:117)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
I've tried with Oracle 1.8 and OpenJDK java with the same results.
Any ideas ?
Thanks
[http://www.etnic.be/fileadmin/BandeauEtnic.png]
ETNIC [http://www.etnic.be/fileadmin/LogoEtnic.png]
LE partenaire informatique du progr?s de la F?d?ration Wallonie-Bruxelles
B?timent Le Z?nith - Boulevard du Roi Albert II, 37 - 1030 Bruxelles
http://www.etnic.be
Disclaimer ETNIC<http://www.etnic.be/index.php?id=537>
Re: Issue with GeoEnrichIP in NiFi 1.8.0
Posted by Mark Payne <ma...@hotmail.com>.
Philippe,
Thanks for reporting this. I have been able to replicate the issue. I created [1] to address the issue and just
posted a Pull Request.
Thanks
-Mark
[1] https://issues.apache.org/jira/browse/NIFI-5814
On Nov 12, 2018, at 5:36 AM, PEETERS Philippe <ph...@etnic.be>> wrote:
Hello,
I’ve installed Nifi 1.8.0 and import the processes developed and running with nifi 1.7.1. It looks like the GeoEnrichIP doesn’t work correctly anymore in 1.8.0.
To be sure I’ve done a clean install of 1.8.0 and defined a simple process:
GenerateFlowFile -> GeoEnrichIP -> LogAttribute
using the same maxmind database used in 1.7.1 : GeoLite2-City.mmdb
Any match generates an exception:
2018-11-12 11:23:57,817 ERROR [Timer-Driven Process Thread-2] org.apache.nifi.pr
ocessors.GeoEnrichIP GeoEnrichIP[id=0730375f-0167-1000-7c0a-6ae0f575136a] GeoEnr
ichIP[id=0730375f-0167-1000-7c0a-6ae0f575136a] failed to process session due to
java.lang.UnsupportedOperationException; Processor Administratively Yielded for 1 sec: java.lang.UnsupportedOperationException
java.lang.UnsupportedOperationException: null
at java.util.Collections$UnmodifiableMap.put(Collections.java:1457)
at com.fasterxml.jackson.databind.node.ObjectNode.set(ObjectNode.java:370)
at org.apache.nifi.processors.maxmind.DatabaseReader.get(DatabaseReader.java:174)
at org.apache.nifi.processors.maxmind.DatabaseReader.city(DatabaseReader.java:211)
at org.apache.nifi.processors.GeoEnrichIP.onTrigger(GeoEnrichIP.java:103)
at org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27)
at org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1165)
at org.apache.nifi.controller.tasks.ConnectableTask.invoke(ConnectableTask.java:203)
at org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:117)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
I’ve tried with Oracle 1.8 and OpenJDK java with the same results.
Any ideas ?
Thanks
[http://www.etnic.be/fileadmin/BandeauEtnic.png]
ETNIC [http://www.etnic.be/fileadmin/LogoEtnic.png]
LE partenaire informatique du progrès de la Fédération Wallonie-Bruxelles
Bâtiment Le Zénith - Boulevard du Roi Albert II, 37 - 1030 Bruxelles
http://www.etnic.be<http://www.etnic.be/>
Disclaimer ETNIC<http://www.etnic.be/index.php?id=537>