From c23f4c417f1cb779cdd9a337ceec5750f0830338 Mon Sep 17 00:00:00 2001
From: "jeffzhang.zjf" <jeffzhang.zjf@alibaba-inc.com>
Date: Thu, 13 May 2021 22:40:37 +0800
Subject: [PATCH] [OOZIE-3622] No mapreduce jars in the classpath for hadoop3
 mapreduce job

---
 .../oozie/action/hadoop/MapReduceActionExecutor.java       | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git a/core/src/main/java/org/apache/oozie/action/hadoop/MapReduceActionExecutor.java b/core/src/main/java/org/apache/oozie/action/hadoop/MapReduceActionExecutor.java
index b8d3b09633..6381f9c5b9 100644
--- a/core/src/main/java/org/apache/oozie/action/hadoop/MapReduceActionExecutor.java
+++ b/core/src/main/java/org/apache/oozie/action/hadoop/MapReduceActionExecutor.java
@@ -474,6 +474,13 @@ protected String findYarnApplicationId(final Context context, final WorkflowActi
         }
     }
 
+    @Override
+    protected void addActionSpecificEnvVars(Map<String, String> env) {
+        // need to specify HADOOP_MAPRED_HOME for hadoop3, otherwise mapreduce jars won't be included
+        // in the launcher's CLASSPATH.
+        env.put("HADOOP_MAPRED_HOME", "${HADOOP_HOME}");
+    }
+
     /**
      * Finds a Hadoop job ID based on {@code action-data.seq} file stored on HDFS by {@link MapReduceMain}.
      */