MAPREDUCE-6621. Memory Leak in JobClient#submitJobInternal(). Contributed by Xuan Gong
(cherry picked from commit 43e669b22d
)
This commit is contained in:
parent
60d3a3c30b
commit
4ee0977687
|
@ -450,6 +450,9 @@ Release 2.7.3 - UNRELEASED
|
|||
MAPREDUCE-6618. YarnClientProtocolProvider leaking the YarnClient thread.
|
||||
(Xuan Gong via jlowe)
|
||||
|
||||
MAPREDUCE-6621. Memory Leak in JobClient#submitJobInternal() (Xuan Gong
|
||||
via jlowe)
|
||||
|
||||
Release 2.7.2 - 2016-01-25
|
||||
|
||||
INCOMPATIBLE CHANGES
|
||||
|
@ -755,6 +758,9 @@ Release 2.6.4 - UNRELEASED
|
|||
MAPREDUCE-6618. YarnClientProtocolProvider leaking the YarnClient thread.
|
||||
(Xuan Gong via jlowe)
|
||||
|
||||
MAPREDUCE-6621. Memory Leak in JobClient#submitJobInternal() (Xuan Gong
|
||||
via jlowe)
|
||||
|
||||
Release 2.6.3 - 2015-12-17
|
||||
|
||||
INCOMPATIBLE CHANGES
|
||||
|
|
|
@ -577,10 +577,18 @@ public class JobClient extends CLI implements AutoCloseable {
|
|||
return job;
|
||||
}
|
||||
});
|
||||
|
||||
Cluster prev = cluster;
|
||||
// update our Cluster instance with the one created by Job for submission
|
||||
// (we can't pass our Cluster instance to Job, since Job wraps the config
|
||||
// instance, and the two configs would then diverge)
|
||||
cluster = job.getCluster();
|
||||
|
||||
// It is important to close the previous cluster instance
|
||||
// to cleanup resources.
|
||||
if (prev != null) {
|
||||
prev.close();
|
||||
}
|
||||
return new NetworkedJob(job);
|
||||
} catch (InterruptedException ie) {
|
||||
throw new IOException("interrupted", ie);
|
||||
|
|
Loading…
Reference in New Issue