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