[importer] Fixed Flume source import properties initialization
@@ -590,6 +590,14 @@ def _envelope_job(request, file_format, destination, start_time=None, lib_path=N
milliseconds = 60000
}'''
elif file_format['inputFormat'] == 'connector':
+ if file_format['streamSelection'] == 'flume':
+ properties = {
+ 'streamSelection': file_format['streamSelection'],
+ 'channelSourceHosts': file_format['channelSourceHosts'],
+ 'channelSourceSelectedHosts': file_format['channelSourceSelectedHosts'],
+ 'channelSourcePath': file_format['channelSourcePath'],
+ }
+ else:
# sfdc
properties = {
'streamSelection': file_format['streamSelection'],
