Daniel Skates created NIFI-5393: ----------------------------------- Summary: ReportLineageToAtlas fails for Key: NIFI-5393 URL: https://issues.apache.org/jira/browse/NIFI-5393 Project: Apache NiFi Issue Type: Bug Affects Versions: 1.5.0 Reporter: Daniel Skates
*Description:* The ReportLineageToAtlas reporting task analyses provenance events and reports to Atlas. Currently, the RAW protocol for Remote Processing Groups is not supported, only HTTP S2S protocol can be reported. *Relevant code:* Method: URL parseUrl(String url) Class: org.apache.nifi.atlas.provenance.AbstractNiFiProvenanceEventAnalyzer Bundle: nifi-atlas-bundle [https://github.com/apache/nifi/blob/79a7014a95dc3087f88248c732fb1e4ad8e6e128/nifi-nar-bundles/nifi-atlas-bundle/nifi-atlas-reporting-task/src/main/java/org/apache/nifi/atlas/provenance/AbstractNiFiProvenanceEventAnalyzer.java#L49] *Relevant exception:* {code:java} 2018-06-11 05:00:11,407 ERROR [Timer-Driven Process Thread-18] o.a.n.a.reporting.ReportLineageToAtlas ReportLineageToAtlas[id=da4632be-779e-1cc3-b480-242c8c36e612] Skipping failed analyzing event ProvenanceEventRecord [eventId=7426097546, eventType=RECEIVE, eventTime=Mon Jun 11 04:47:36 AWST 2018, uuid=2ff2cb97-5011-47c9-b881-577989f21980, fileSize=10, componentId=de0df916-0163-1000-8497-cc7e7cd614d1, transitUri=nifi://nifi.example.com:8000/d57e73e1-fdd6-492b-9945-b6059df02976, sourceSystemFlowFileIdentifier=urn:nifi:d57e73e1-fdd6-492b-9945-b6059df02976, parentUuids=[], alternateIdentifierUri=null] due to java.lang.IllegalArgumentException: Failed to parse url nifi://nifi.example.com:8000/d57e73e1-fdd6-492b-9945-b6059df02976 due to java.net.MalformedURLException: unknown protocol: nifi.: java.lang.IllegalArgumentException: Failed to parse url nifi://nifi.example.com:8000/d57e73e1-fdd6-492b-9945-b6059df02976 due to java.net.MalformedURLException: unknown protocol: nifi java.lang.IllegalArgumentException: Failed to parse url nifi://nifi.example.com:8000/d57e73e1-fdd6-492b-9945-b6059df02976 due to java.net.MalformedURLException: unknown protocol: nifi at org.apache.nifi.atlas.provenance.AbstractNiFiProvenanceEventAnalyzer.parseUrl(AbstractNiFiProvenanceEventAnalyzer.java:54) at org.apache.nifi.atlas.provenance.analyzer.NiFiS2S.parseTransitURL(NiFiS2S.java:36) at org.apache.nifi.atlas.provenance.analyzer.NiFiRootGroupPort.analyze(NiFiRootGroupPort.java:57) at org.apache.nifi.atlas.provenance.lineage.AbstractLineageStrategy.executeAnalyzer(AbstractLineageStrategy.java:70) at org.apache.nifi.atlas.provenance.lineage.SimpleFlowPathLineage.processEvent(SimpleFlowPathLineage.java:41) at org.apache.nifi.atlas.reporting.ReportLineageToAtlas.lambda$consumeNiFiProvenanceEvents$8(ReportLineageToAtlas.java:666) at org.apache.nifi.reporting.util.provenance.ProvenanceEventConsumer.consumeEvents(ProvenanceEventConsumer.java:204) at org.apache.nifi.atlas.reporting.ReportLineageToAtlas.consumeNiFiProvenanceEvents(ReportLineageToAtlas.java:663) at org.apache.nifi.atlas.reporting.ReportLineageToAtlas.onTrigger(ReportLineageToAtlas.java:615) at org.apache.nifi.controller.tasks.ReportingTaskWrapper.run(ReportingTaskWrapper.java:41) 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) Caused by: java.net.MalformedURLException: unknown protocol: nifi at java.net.URL.<init>(URL.java:600) at java.net.URL.<init>(URL.java:490) at java.net.URL.<init>(URL.java:439) at org.apache.nifi.atlas.provenance.AbstractNiFiProvenanceEventAnalyzer.parseUrl(AbstractNiFiProvenanceEventAnalyzer.java:51) ... 16 common frames omitted{code} -- This message was sent by Atlassian JIRA (v7.6.3#76005)