[
https://issues.apache.org/jira/browse/NIFI-5393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Koji Kawamura resolved NIFI-5393.
---------------------------------
Resolution: Fixed
Fix Version/s: 1.8.0
Fixed by NIFI-4654.
> 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
> Assignee: Koji Kawamura
> Priority: Major
> Labels: atlas, lineage, site-to-site
> Fix For: 1.8.0
>
>
> *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)
