需要增加我的MapReduce作业的协商超时。

我尝试设置以下属性:

Configuration conf = new Configuration();
conf.set("zk.connectiontimeout.ms", "60000");

但这没有帮助。仍然继续收到下面给出的消息。如何以编程方式更改此值?

这是消息:

15/03/27 11:46:40信息zookeeper.ClientCnxn:服务器上的 session 建立完成,sessionid = 0x14bxxbbf2c9e,协商超时= 30000

最佳答案

ZooKeeper配置仅在启动时由ZooKeeper服务器使用。它们已经运行后,您将无法对其进行更改。

关于hadoop - 在MapReduce作业中增加ZooKeeper协商的超时,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/29308609/

10-16 18:06