瀏覽代碼

YARN-633. Changed RMAdminProtocol api to throw IOException and YarnRemoteException. Contributed by Xuan Gong.

git-svn-id: https://svn.apache.org/repos/asf/hadoop/common/trunk@1479738 13f79535-47bb-0310-9956-ffa450edef68
Vinod Kumar Vavilapalli 12 年之前
父節點
當前提交
674cf7f742

+ 3 - 0
hadoop-yarn-project/CHANGES.txt

@@ -109,6 +109,9 @@ Release 2.0.5-beta - UNRELEASED
     YARN-629. Make YarnRemoteException not be rooted at IOException. (Xuan Gong
     YARN-629. Make YarnRemoteException not be rooted at IOException. (Xuan Gong
     via vinodkv)
     via vinodkv)
 
 
+    YARN-633. Changed RMAdminProtocol api to throw IOException and
+    YarnRemoteException. (Xuan Gong via vinodkv)
+
   NEW FEATURES
   NEW FEATURES
 
 
     YARN-482. FS: Extend SchedulingMode to intermediate queues. 
     YARN-482. FS: Extend SchedulingMode to intermediate queues. 

+ 8 - 6
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/RMAdminProtocol.java

@@ -18,6 +18,8 @@
 
 
 package org.apache.hadoop.yarn.api;
 package org.apache.hadoop.yarn.api;
 
 
+import java.io.IOException;
+
 import org.apache.hadoop.tools.GetUserMappingsProtocol;
 import org.apache.hadoop.tools.GetUserMappingsProtocol;
 import org.apache.hadoop.yarn.exceptions.YarnRemoteException;
 import org.apache.hadoop.yarn.exceptions.YarnRemoteException;
 import org.apache.hadoop.yarn.api.protocolrecords.RefreshAdminAclsRequest;
 import org.apache.hadoop.yarn.api.protocolrecords.RefreshAdminAclsRequest;
@@ -35,25 +37,25 @@ import org.apache.hadoop.yarn.api.protocolrecords.RefreshUserToGroupsMappingsRes
 
 
 public interface RMAdminProtocol extends GetUserMappingsProtocol {
 public interface RMAdminProtocol extends GetUserMappingsProtocol {
   public RefreshQueuesResponse refreshQueues(RefreshQueuesRequest request) 
   public RefreshQueuesResponse refreshQueues(RefreshQueuesRequest request) 
-  throws YarnRemoteException;
+  throws YarnRemoteException, IOException;
   
   
   public RefreshNodesResponse refreshNodes(RefreshNodesRequest request)
   public RefreshNodesResponse refreshNodes(RefreshNodesRequest request)
-  throws YarnRemoteException;
+  throws YarnRemoteException, IOException;
   
   
   public RefreshSuperUserGroupsConfigurationResponse 
   public RefreshSuperUserGroupsConfigurationResponse 
   refreshSuperUserGroupsConfiguration(
   refreshSuperUserGroupsConfiguration(
       RefreshSuperUserGroupsConfigurationRequest request)
       RefreshSuperUserGroupsConfigurationRequest request)
-  throws YarnRemoteException;
+  throws YarnRemoteException, IOException;
 
 
   public RefreshUserToGroupsMappingsResponse refreshUserToGroupsMappings(
   public RefreshUserToGroupsMappingsResponse refreshUserToGroupsMappings(
       RefreshUserToGroupsMappingsRequest request)
       RefreshUserToGroupsMappingsRequest request)
-  throws YarnRemoteException;
+  throws YarnRemoteException, IOException;
   
   
   public RefreshAdminAclsResponse refreshAdminAcls(
   public RefreshAdminAclsResponse refreshAdminAcls(
       RefreshAdminAclsRequest request)
       RefreshAdminAclsRequest request)
-  throws YarnRemoteException;
+  throws YarnRemoteException, IOException;
   
   
   public RefreshServiceAclsResponse refreshServiceAcls(
   public RefreshServiceAclsResponse refreshServiceAcls(
       RefreshServiceAclsRequest request)
       RefreshServiceAclsRequest request)
-  throws YarnRemoteException;
+  throws YarnRemoteException, IOException;
 }
 }

+ 12 - 0
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/impl/pb/service/RMAdminProtocolPBServiceImpl.java

@@ -63,6 +63,8 @@ public class RMAdminProtocolPBServiceImpl implements RMAdminProtocolPB {
       return ((RefreshQueuesResponsePBImpl)response).getProto();
       return ((RefreshQueuesResponsePBImpl)response).getProto();
     } catch (YarnRemoteException e) {
     } catch (YarnRemoteException e) {
       throw new ServiceException(e);
       throw new ServiceException(e);
+    } catch (IOException e) {
+      throw new ServiceException(e);
     }
     }
   }
   }
 
 
@@ -77,6 +79,8 @@ public class RMAdminProtocolPBServiceImpl implements RMAdminProtocolPB {
       return ((RefreshAdminAclsResponsePBImpl)response).getProto();
       return ((RefreshAdminAclsResponsePBImpl)response).getProto();
     } catch (YarnRemoteException e) {
     } catch (YarnRemoteException e) {
       throw new ServiceException(e);
       throw new ServiceException(e);
+    } catch (IOException e) {
+      throw new ServiceException(e);
     }
     }
   }
   }
 
 
@@ -89,6 +93,8 @@ public class RMAdminProtocolPBServiceImpl implements RMAdminProtocolPB {
       return ((RefreshNodesResponsePBImpl)response).getProto();
       return ((RefreshNodesResponsePBImpl)response).getProto();
     } catch (YarnRemoteException e) {
     } catch (YarnRemoteException e) {
       throw new ServiceException(e);
       throw new ServiceException(e);
+    } catch (IOException e) {
+      throw new ServiceException(e);
     }
     }
   }
   }
 
 
@@ -106,6 +112,8 @@ public class RMAdminProtocolPBServiceImpl implements RMAdminProtocolPB {
       return ((RefreshSuperUserGroupsConfigurationResponsePBImpl)response).getProto();
       return ((RefreshSuperUserGroupsConfigurationResponsePBImpl)response).getProto();
     } catch (YarnRemoteException e) {
     } catch (YarnRemoteException e) {
       throw new ServiceException(e);
       throw new ServiceException(e);
+    } catch (IOException e) {
+      throw new ServiceException(e);
     }
     }
   }
   }
 
 
@@ -121,6 +129,8 @@ public class RMAdminProtocolPBServiceImpl implements RMAdminProtocolPB {
       return ((RefreshUserToGroupsMappingsResponsePBImpl)response).getProto();
       return ((RefreshUserToGroupsMappingsResponsePBImpl)response).getProto();
     } catch (YarnRemoteException e) {
     } catch (YarnRemoteException e) {
       throw new ServiceException(e);
       throw new ServiceException(e);
+    } catch (IOException e) {
+      throw new ServiceException(e);
     }
     }
   }
   }
 
 
@@ -136,6 +146,8 @@ public class RMAdminProtocolPBServiceImpl implements RMAdminProtocolPB {
         return ((RefreshServiceAclsResponsePBImpl)response).getProto();
         return ((RefreshServiceAclsResponsePBImpl)response).getProto();
       } catch (YarnRemoteException e) {
       } catch (YarnRemoteException e) {
         throw new ServiceException(e);
         throw new ServiceException(e);
+      } catch (IOException e) {
+        throw new ServiceException(e);
       }
       }
   }
   }