I could swear this worked before

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

I could swear this worked before

Geoffry Roberts-2
I am stuck.
It is something simple and I am sure the worked with older Hadoop versions.
Currently, I am running Hadoop 2.9.1.

Question: Why am I getting a null?  Clearly, the value has not been set, but why?

Driver code:

...
Configuration conf = new Configuration;

Job job = Job.getInstance(conf"somejobname");

conf.set("ZOOKEEPER_URI", "http://localhost:2181");

...


Mapper code:


...

protected void setup(Context ctx) throws IOException, InterruptedException {


Configuration conf = ctx.getConfiguration();

String zkURI = conf.get("ZOOKEEPER_URI");  

// Here's the problem: zkURI is null.

}
System.out.println(ctx.getJobName());  // prints "somejobname" as expected.
...

Thanks all

-- 
There are ways and there are ways, 

Geoffry Roberts