Apache/hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

MAPREDUCE-6431. JobClient should be an AutoClosable (haibochen via rkanter)

Browse Source 
(cherry picked from commit dca0dc8ac28e843acd8b79c9560245638a539fde)
This commit is contained in:
Robert Kanter 2016-01-27 17:11:07 -08:00
parent d7982222fa
commit a99fa74490
3 changed files with 14 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
hadoop-mapreduce-project/CHANGES.txt
View File

@ -8,6 +8,8 @@ Release 2.9.0 - UNRELEASED
IMPROVEMENTS
MAPREDUCE-6431. JobClient should be an AutoClosable (haibochen via rkanter)
OPTIMIZATIONS
BUG FIXES

10
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-common/src/test/java/org/apache/hadoop/mapred/TestJobClient.java
View File

@ -87,4 +87,14 @@ public void testGetStagingAreaDir() throws IOException, InterruptedException {
client.getClusterHandle().getStagingAreaDir().toString()
.equals(client.getStagingAreaDir().toString()));
}
/**
* Asks the compiler to check if JobClient is AutoClosable.
*/
@Test(timeout = 10000)
public void testAutoClosable() throws IOException {
Configuration conf = new Configuration();
try (JobClient jobClient = new JobClient(conf)) {
}
}
}

3
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapred/JobClient.java
View File

@ -137,7 +137,7 @@
*/
@InterfaceAudience.Public
@InterfaceStability.Stable
public class JobClient extends CLI {
public class JobClient extends CLI implements AutoCloseable {
@InterfaceAudience.Private
public static final String MAPREDUCE_CLIENT_RETRY_POLICY_ENABLED_KEY =
@ -499,6 +499,7 @@ public JobClient(InetSocketAddress jobTrackAddr,
/**
* Close the <code>JobClient</code>.
*/
@Override
public synchronized void close() throws IOException {
cluster.close();
}