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

YARN-651. Changed PBClientImpls of ContainerManager and RMAdmin to throw IOExceptions also. Contributed by Xuan Gong. 

svn merge --ignore-ancestry -c 1480154 ../../trunk/


git-svn-id: https://svn.apache.org/repos/asf/hadoop/common/branches/branch-2@1480155 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Vinod Kumar Vavilapalli 2013-05-08 04:17:40 +00:00
parent 0effce3ff0
commit e5ce72fb4e
3 changed files with 15 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
hadoop-yarn-project/CHANGES.txt
View File

@ -147,6 +147,9 @@ Release 2.0.5-beta - UNRELEASED
YARN-645. Moved RMDelegationTokenSecretManager from yarn-server-common to YARN-645. Moved RMDelegationTokenSecretManager from yarn-server-common to
yarn-server-resourcemanager where it really belongs. (Jian He via vinodkv) yarn-server-resourcemanager where it really belongs. (Jian He via vinodkv)
YARN-651. Changed PBClientImpls of ContainerManager and RMAdmin to throw
IOExceptions also. (Xuan Gong via vinodkv)
OPTIMIZATIONS OPTIMIZATIONS
BUG FIXES BUG FIXES

7
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/impl/pb/client/ContainerManagerPBClientImpl.java
View File

@ -86,7 +86,8 @@ public class ContainerManagerPBClientImpl implements ContainerManager,
@Override @Override
public GetContainerStatusResponse getContainerStatus( public GetContainerStatusResponse getContainerStatus(
GetContainerStatusRequest request) throws YarnRemoteException { GetContainerStatusRequest request) throws YarnRemoteException,
IOException {
GetContainerStatusRequestProto requestProto = GetContainerStatusRequestProto requestProto =
((GetContainerStatusRequestPBImpl) request).getProto(); ((GetContainerStatusRequestPBImpl) request).getProto();
try { try {
@ -99,7 +100,7 @@ public class ContainerManagerPBClientImpl implements ContainerManager,
@Override @Override
public StartContainerResponse startContainer(StartContainerRequest request) public StartContainerResponse startContainer(StartContainerRequest request)
throws YarnRemoteException { throws YarnRemoteException, IOException {
StartContainerRequestProto requestProto = StartContainerRequestProto requestProto =
((StartContainerRequestPBImpl) request).getProto(); ((StartContainerRequestPBImpl) request).getProto();
try { try {
@ -112,7 +113,7 @@ public class ContainerManagerPBClientImpl implements ContainerManager,
@Override @Override
public StopContainerResponse stopContainer(StopContainerRequest request) public StopContainerResponse stopContainer(StopContainerRequest request)
throws YarnRemoteException { throws YarnRemoteException, IOException {
StopContainerRequestProto requestProto = StopContainerRequestProto requestProto =
((StopContainerRequestPBImpl) request).getProto(); ((StopContainerRequestPBImpl) request).getProto();
try { try {

14
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/impl/pb/client/RMAdminProtocolPBClientImpl.java
View File

@ -87,7 +87,7 @@ public class RMAdminProtocolPBClientImpl implements RMAdminProtocol, Closeable {
@Override @Override
public RefreshQueuesResponse refreshQueues(RefreshQueuesRequest request) public RefreshQueuesResponse refreshQueues(RefreshQueuesRequest request)
throws YarnRemoteException { throws YarnRemoteException, IOException {
RefreshQueuesRequestProto requestProto = RefreshQueuesRequestProto requestProto =
((RefreshQueuesRequestPBImpl)request).getProto(); ((RefreshQueuesRequestPBImpl)request).getProto();
try { try {
@ -100,7 +100,7 @@ public class RMAdminProtocolPBClientImpl implements RMAdminProtocol, Closeable {
@Override @Override
public RefreshNodesResponse refreshNodes(RefreshNodesRequest request) public RefreshNodesResponse refreshNodes(RefreshNodesRequest request)
throws YarnRemoteException { throws YarnRemoteException, IOException {
RefreshNodesRequestProto requestProto = RefreshNodesRequestProto requestProto =
((RefreshNodesRequestPBImpl)request).getProto(); ((RefreshNodesRequestPBImpl)request).getProto();
try { try {
@ -114,7 +114,7 @@ public class RMAdminProtocolPBClientImpl implements RMAdminProtocol, Closeable {
@Override @Override
public RefreshSuperUserGroupsConfigurationResponse refreshSuperUserGroupsConfiguration( public RefreshSuperUserGroupsConfigurationResponse refreshSuperUserGroupsConfiguration(
RefreshSuperUserGroupsConfigurationRequest request) RefreshSuperUserGroupsConfigurationRequest request)
throws YarnRemoteException { throws YarnRemoteException, IOException {
RefreshSuperUserGroupsConfigurationRequestProto requestProto = RefreshSuperUserGroupsConfigurationRequestProto requestProto =
((RefreshSuperUserGroupsConfigurationRequestPBImpl)request).getProto(); ((RefreshSuperUserGroupsConfigurationRequestPBImpl)request).getProto();
try { try {
@ -127,7 +127,8 @@ public class RMAdminProtocolPBClientImpl implements RMAdminProtocol, Closeable {
@Override @Override
public RefreshUserToGroupsMappingsResponse refreshUserToGroupsMappings( public RefreshUserToGroupsMappingsResponse refreshUserToGroupsMappings(
RefreshUserToGroupsMappingsRequest request) throws YarnRemoteException { RefreshUserToGroupsMappingsRequest request) throws YarnRemoteException,
IOException {
RefreshUserToGroupsMappingsRequestProto requestProto = RefreshUserToGroupsMappingsRequestProto requestProto =
((RefreshUserToGroupsMappingsRequestPBImpl)request).getProto(); ((RefreshUserToGroupsMappingsRequestPBImpl)request).getProto();
try { try {
@ -140,7 +141,7 @@ public class RMAdminProtocolPBClientImpl implements RMAdminProtocol, Closeable {
@Override @Override
public RefreshAdminAclsResponse refreshAdminAcls( public RefreshAdminAclsResponse refreshAdminAcls(
RefreshAdminAclsRequest request) throws YarnRemoteException { RefreshAdminAclsRequest request) throws YarnRemoteException, IOException {
RefreshAdminAclsRequestProto requestProto = RefreshAdminAclsRequestProto requestProto =
((RefreshAdminAclsRequestPBImpl)request).getProto(); ((RefreshAdminAclsRequestPBImpl)request).getProto();
try { try {
@ -153,7 +154,8 @@ public class RMAdminProtocolPBClientImpl implements RMAdminProtocol, Closeable {
@Override @Override
public RefreshServiceAclsResponse refreshServiceAcls( public RefreshServiceAclsResponse refreshServiceAcls(
RefreshServiceAclsRequest request) throws YarnRemoteException { RefreshServiceAclsRequest request) throws YarnRemoteException,
IOException {
RefreshServiceAclsRequestProto requestProto = RefreshServiceAclsRequestProto requestProto =
((RefreshServiceAclsRequestPBImpl)request).getProto(); ((RefreshServiceAclsRequestPBImpl)request).getProto();
try { try {