Created on 11-21-2016 06:14 PM - edited 08-19-2019 04:03 AM
Hi guys,
We have Flume setup on the Hadoop cluster and it is working. I am trying to use the Flume data as source in NiFi, I set up the required properties in NiFi's ExecuteFlumeSource processor, but it gives "unable to load source type" error.
Any thoughts on what's causing the error?
Thank you.
Created 11-21-2016 08:58 PM
@Raj B Here are the flume source types. In the documentation for each source type you will see the type Property defines the string to use in the SourceType field.
https://flume.apache.org/FlumeUserGuide.html#flume-sources
For example if look at JMS Source, the type property specifies the component type name is jms.
HL7 is a data format but the source type for flume is a protocol that describes how the data is delivered. For example HL7 format data could be delivered using Kafka.
If the HL7 data is already delivered using flume, check the config files to see what the source type value is.
Created 11-21-2016 07:36 PM
@Raj B Check the value of the SourceType field in the ExecuteFlumeSource. The type should be valid source type, i.e. avro, thrift, netcat, etc.
Check out the @Timothy Spann article on using flume with NiFi:
Created on 11-21-2016 08:35 PM - edited 08-19-2019 04:03 AM
@cduby I was following the example in the NiFi documentation; looking at the example it didn't seem there were a set of standard source types; @Timothy Spann's article didn't say anything about the source types being preset few either; do you know what source type to use if my incoming data is in HL7 format.
Created 11-21-2016 08:58 PM
@Raj B Here are the flume source types. In the documentation for each source type you will see the type Property defines the string to use in the SourceType field.
https://flume.apache.org/FlumeUserGuide.html#flume-sources
For example if look at JMS Source, the type property specifies the component type name is jms.
HL7 is a data format but the source type for flume is a protocol that describes how the data is delivered. For example HL7 format data could be delivered using Kafka.
If the HL7 data is already delivered using flume, check the config files to see what the source type value is.
Created 11-21-2016 09:12 PM
thanks @cduby, I see what you're saying. Let me check what I need to use for source type in my case.