Description
org.apache.falcon.converter.OozieProcessMapper generates input params assuming input as the name rather than using user provided name which results in coordinator submission failure. Same is true of output as well.
This is true only if input and output are of table storage but not file system.
props.put(prefix + "_partition_filter_pig", "${coord:dataInPartitionFilter('input', 'pig')}"); props.put(prefix + "_partition_filter_hive", "${coord:dataInPartitionFilter('input', 'hive')}"); props.put(prefix + "_partition_filter_java", "${coord:dataInPartitionFilter('input', 'java')}"); props.put(prefix + "_dataout_partitions", "${coord:dataOutPartitions('output')}");
Attachments
Attachments
Issue Links
- is duplicated by
-
FALCON-214 Process scheduling fails in oozie
- Closed