2016-12-21 3 views
0

В моей прикладной программе используется rpc hadoop для удаленного отправления/получения запросов в распределенной среде.Как настроить тайм-аут hadoop rpc?

org.apache.hadoop.ipc.RPC; 
org.apache.hadoop.ipc.RPC.Server; 

.... 

this.server = RPC.getServer(this, this.peerAddr.getHostName(), this.peerAddr.getPort(), this.conf); 
this.server.start(); 

Поскольку задачи получить тяжелее, я наблюдаю частые сбои задачи из-за IO Exception (что, возможно, вызвано резьбы прерываний).

Я подозреваю, что исключение вызвано таймаутом RPC.

Как настроить тайм-аут для RPC в hadoop? Например, то, что я ожидал что-то вроде ...

<property> 
<name>hadoop.rpc.timeout</name> 
<value>3000</value> 
<description>The timeout for RPC call in ms</description> 
</property> 
+0

Hadoop версии ?? – mrsrinivas

+0

@mrsrinivas версия Hadoop 0.20, которая довольно старая. (Framework использует эту версию, которую я не знаю почему) – syko

ответ

1

Hadoop 0,20 не поддерживает это, пожалуйста, прочитайте этому вопросу https://issues.apache.org/jira/browse/HADOOP-6889

+0

Я могу увидеть переменную «RpcTimeout» в коде клиента adoop ipc. (Http://grepcode.com/file/repo1.maven.org/maven2/com.ning/metrics.action/0.2.0/org/apache/hadoop/ipc/Client.java) – syko

 Смежные вопросы

  • Нет связанных вопросов^_^