From af19ecda7d63eaf00cd4f188952601b7d293fa74 Mon Sep 17 00:00:00 2001 From: csun1 Date: Wed, 20 Mar 2019 13:55:44 +0800 Subject: [PATCH] [GIRAPH-1110] use Configuration.setInt instead of Client.setPingInterval --- giraph-core/src/main/java/org/apache/giraph/job/GiraphJob.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/giraph-core/src/main/java/org/apache/giraph/job/GiraphJob.java b/giraph-core/src/main/java/org/apache/giraph/job/GiraphJob.java index b11f1312f..1957dbecf 100644 --- a/giraph-core/src/main/java/org/apache/giraph/job/GiraphJob.java +++ b/giraph-core/src/main/java/org/apache/giraph/job/GiraphJob.java @@ -25,7 +25,6 @@ import org.apache.giraph.conf.ImmutableClassesGiraphConfiguration; import org.apache.giraph.graph.GraphMapper; import org.apache.hadoop.conf.Configuration; -import org.apache.hadoop.ipc.Client; import org.apache.hadoop.mapreduce.Job; import org.apache.log4j.Logger; @@ -210,7 +209,7 @@ public final boolean run(boolean verbose) // Set the ping interval to 5 minutes instead of one minute // (DEFAULT_PING_INTERVAL) - Client.setPingInterval(giraphConfiguration, 60000 * 5); + giraphConfiguration.setInt("ipc.ping.interval", 60000 * 5); // Should work in MAPREDUCE-1938 to let the user jars/classes // get loaded first