You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@oozie.apache.org by ka...@apache.org on 2012/11/14 02:16:48 UTC
svn commit: r1409049 - in /oozie/branches/branch-3.3:
core/src/main/java/org/apache/oozie/action/hadoop/LauncherMapper.java
release-log.txt
Author: kamrul
Date: Wed Nov 14 01:16:47 2012
New Revision: 1409049
URL: http://svn.apache.org/viewvc?rev=1409049&view=rev
Log:
OOZIE-1052 HadoopAccessorService.createFileSystem throws exception in map-reduce action, failing workflow.(ryota via mohammad).
Modified:
oozie/branches/branch-3.3/core/src/main/java/org/apache/oozie/action/hadoop/LauncherMapper.java
oozie/branches/branch-3.3/release-log.txt
Modified: oozie/branches/branch-3.3/core/src/main/java/org/apache/oozie/action/hadoop/LauncherMapper.java
URL: http://svn.apache.org/viewvc/oozie/branches/branch-3.3/core/src/main/java/org/apache/oozie/action/hadoop/LauncherMapper.java?rev=1409049&r1=1409048&r2=1409049&view=diff
==============================================================================
--- oozie/branches/branch-3.3/core/src/main/java/org/apache/oozie/action/hadoop/LauncherMapper.java (original)
+++ oozie/branches/branch-3.3/core/src/main/java/org/apache/oozie/action/hadoop/LauncherMapper.java Wed Nov 14 01:16:47 2012
@@ -316,8 +316,9 @@ public class LauncherMapper<K1, V1, K2,
Path p = getIdSwapPath(actionDir);
// log.debug("Checking for newId file in: [{0}]", p);
- FileSystem fs = Services.get().get(HadoopAccessorService.class).createFileSystem(user, p.toUri(),
- new Configuration());
+ HadoopAccessorService has = Services.get().get(HadoopAccessorService.class);
+ Configuration conf = has.createJobConf(p.toUri().getAuthority());
+ FileSystem fs = has.createFileSystem(user, p.toUri(), conf);
if (fs.exists(p)) {
log.debug("Hadoop Counters is null, but found newID file.");
Modified: oozie/branches/branch-3.3/release-log.txt
URL: http://svn.apache.org/viewvc/oozie/branches/branch-3.3/release-log.txt?rev=1409049&r1=1409048&r2=1409049&view=diff
==============================================================================
--- oozie/branches/branch-3.3/release-log.txt (original)
+++ oozie/branches/branch-3.3/release-log.txt Wed Nov 14 01:16:47 2012
@@ -1,5 +1,6 @@
-- Oozie 3.3.0 release (unreleased)
+OOZIE-1052 HadoopAccessorService.createFileSystem throws exception in map-reduce action, failing workflow.(ryota via mohammad).
OOZIE-1060 bump hadoop 2.X version to 2.0.2-alpha (rvs via tucu)
OOZIE-959 Use API from OOZIE-906 in console (Ashish via Mohammad)
OOZIE-1027 Command line mr does not support NN/JT parameters properly (Mona via Mohammad)