Issue with forward slash '/' getting removed in a job argument

[Jonathan Hodges]

Hi,

The following is my workflow.xml and properties file for the Java action.

<workflow-app xmlns="uri:oozie:workflow:0.5" name="camus-wf">
    <start to="camusNonAvroJob"/>
    <action name="camusNonAvroJob">
        <java>
            <job-tracker>${jobTracker}</job-tracker>
            <name-node>${nameNode}</name-node>
            <configuration>
            <property>
                    <name>mapred.job.name</name>
                    <value>camusNonAvroJob</value>
                </property>
                <property>
                    <name>mapred.job.queue.name</name>
                    <value>${queueName}</value>
                </property>
            </configuration>
            <main-class>com.linkedin.camus.etl.kafka.CamusJob</main-class>
    <arg>-P</arg>
    <arg>${camusNonAvroJobProperties}</arg>
        </java>
        <ok to="end"/>
        <error to="fail"/>
    </action>
    <kill name="fail">
        <message>${wf:errorMessage(wf:lastErrorNode())}</message>
    </kill>
    <end name="end"/>
</workflow-app>

nameNode=hdfs://x.x.x.x:9000
jobTracker=x.x.x.x:9001
queueName=default
oozie.wf.application.path=${nameNode}/user/${user.name
}/oozie/camusNonAvroJob
camusNonAvroJobProperties=${nameNode}/user/${user.name
}/oozie/camusNonAvroJob/camus_non_avro.properties


This removed forward slash '/' from the HDFS path is causing a file not
found exception and the MR job getting killed.bin/oozie job -config
/home/hadoop/oozie/camusNonAvroJob/camus-workflow.properties -run

Failing Oozie Launcher, Main class
[com.linkedin.camus.etl.kafka.CamusJob], main() threw exception,
hdfs:/x.x.x.x:9000/user/hadoop/oozie/camusNonAvroJob/camus_non_avro.properties
(No such file or directory)
java.io.FileNotFoundException:
hdfs:/x.x.x.x:9000/user/hadoop/oozie/camusNonAvroJob/camus_non_avro.properties
(No such file or directory)
        at java.io.FileInputStream.open(Native Method)
        at java.io.FileInputStream.<init>(FileInputStream.java:146)
        at com.linkedin.camus.etl.kafka.CamusJob.run(CamusJob.java:602)
        at org.apache.hadoop.util.ToolRunner.run(ToolRunner.java:65)
        at org.apache.hadoop.util.ToolRunner.run(ToolRunner.java:79)
        at com.linkedin.camus.etl.kafka.CamusJob.main(CamusJob.java:572)
        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
        at 
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
        at 
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)


Has anyone seen this before?

Thank in advance!
Jonathan