Revert "TEZ-2840. MRInputLegacy.init should set splitInfoViaEvents. (…

…Sergey Shelukhin via hitesh)" This reverts commit 6af43ce. Conflicts: CHANGES.txt
Poneyo · Sep 18, 2015 · 7ed7025 · 7ed7025
1 parent 6930e4b
commit 7ed7025
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 6 deletions.
diff --git a/CHANGES.txt b/CHANGES.txt
@@ -11,7 +11,6 @@ ALL CHANGES:
   TEZ-2812. Preemption sometimes does not respect heartbeats between preemptions
   TEZ-814.  Improve heuristic for determining a task has failed outputs
   TEZ-2832. Support tests for both SimpleHistory logging and ATS logging
-  TEZ-2840. MRInputLegacy.init should set splitInfoViaEvents.
   TEZ-2827. Increase timeout for TestFetcher testInputAttemptIdentifierMap
   TEZ-2774. Improvements and cleanup of logging for the AM and parts of the runtme.
   TEZ-2825. Report progress in terms of completed tasks to reduce load on AM for Tez UI
@@ -189,7 +188,6 @@ ALL CHANGES:
   TEZ-2097. TEZ-UI Add dag logs backend support
   TEZ-2812. Preemption sometimes does not respect heartbeats between preemptions
   TEZ-814.  Improve heuristic for determining a task has failed outputs
-  TEZ-2840. MRInputLegacy.init should set splitInfoViaEvents.
   TEZ-2829. Tez UI: minor fixes to in-progress update of UI from AM
   TEZ-2663. SessionNotRunning exceptions are wrapped in a ServiceException from a dying AM.
   TEZ-2825. Report progress in terms of completed tasks to reduce load on AM for Tez UI

diff --git a/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/input/MRInput.java b/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/input/MRInput.java
@@ -435,6 +435,10 @@ public MRInput(InputContext inputContext, int numPhysicalInputs) {
   public List<Event> initialize() throws IOException {
     super.initialize();
     getContext().inputIsReady();
+    this.splitInfoViaEvents = jobConf.getBoolean(MRJobConfig.MR_TEZ_SPLITS_VIA_EVENTS,
+        MRJobConfig.MR_TEZ_SPLITS_VIA_EVENTS_DEFAULT);
+    LOG.info("Using New mapreduce API: " + useNewApi
+        + ", split information via event: " + splitInfoViaEvents);
     initializeInternal();
     return null;
   }
@@ -448,10 +452,6 @@ public void start() {
 
   @Private
   void initializeInternal() throws IOException {
-    this.splitInfoViaEvents = jobConf.getBoolean(MRJobConfig.MR_TEZ_SPLITS_VIA_EVENTS,
-        MRJobConfig.MR_TEZ_SPLITS_VIA_EVENTS_DEFAULT);
-    LOG.info("Using New mapreduce API: " + useNewApi
-        + ", split information via event: " + splitInfoViaEvents);
     // Primarily for visibility
     rrLock.lock();
     try {