[FLINK-11733] Provide HadoopMapFunction for org.apache.hadoop.mapreduce.Mapper

• Type: Improvement
• Status: Open
• Priority: Not a Priority
• Resolution: Unresolved
• Component/s: Connectors / Hadoop Compatibility
• Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned pull-request-available
• Assignee: Unassigned
• Reporter: vinoyang
• Created: 23/Feb/19 09:47
• Updated: 24/Dec/21 10:39

Description

Currently, Flink only support org.apache.flink.hadoopcompatibility.mapred.Mapper in module flink-hadoop-compatibility. I think we also need to support Hadoop new Mapper API : org.apache.hadoop.mapreduce.Mapper.  We can implement a new HadoopMapFunction to wrap org.apache.hadoop.mapreduce.Mapper.

Issue Links

• links to: GitHub Pull Request #8034