Ryota Egashira created OOZIE-1052:
-------------------------------------

             Summary: HadoopAccessorService.createFileSystem throws exception 
in map-reduce action, failing workflow.
                 Key: OOZIE-1052
                 URL: https://issues.apache.org/jira/browse/OOZIE-1052
             Project: Oozie
          Issue Type: Bug
          Components: core
    Affects Versions: 3.2.0
            Reporter: Ryota Egashira
            Priority: Blocker


HadoopAccessorService.createFileSystem checks 
OOZIE_HADOOP_ACCESSOR_SERVICE_CREATED in jobconf, (which is passed as 
argument), and if false or non-exist, throws exception. 
------
if (!conf.getBoolean(OOZIE_HADOOP_ACCESSOR_SERVICE_CREATED, false)) {
            throw new HadoopAccessorException(ErrorCode.E0903);
}
------

this is troublesome when it's called from LauncherMapper.hasIdSwap, since it 
passes new conf as argument, which doesn't include 
OOZIE_HADOOP_ACCESSOR_SERVICE_CREATED, so always hitting exception mentioned 
above 
-------
FileSystem fs = 
Services.get().get(HadoopAccessorService.class).createFileSystem(user, 
p.toUri(),new Configuration());
--------

this problem becomes visible to user as workflow failure, when in map-reduce 
action, oozie fails to get external jobID from counters, then accessing to HDFS 
to get it.

the above-mentioned change in HadoopAccessorService.createFileSystem is 
introduced in 3.2,  it is not present in 3.1.4.

this needs to be fixed. also question is what was original intention of the 
change. 



--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira

Reply via email to