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>