@Override public KerberosInfo getKerberosInfo(Class<?> protocol, Configuration conf) { if (!protocol.equals(ResourceManagerAdministrationProtocolPB.class)) { return null; } return new KerberosInfo() { @Override public Class<? extends Annotation> annotationType() { return null; } @Override public String serverPrincipal() { return YarnConfiguration.RM_PRINCIPAL; } @Override public String clientPrincipal() { return null; } }; }
@Override public KerberosInfo getKerberosInfo(Class<?> protocol, Configuration conf) { if (!protocol .equals(ApplicationClientProtocolPB.class)) { return null; } return new KerberosInfo() { @Override public Class<? extends Annotation> annotationType() { return null; } @Override public String serverPrincipal() { return YarnConfiguration.RM_PRINCIPAL; } @Override public String clientPrincipal() { return null; } }; }
@Override public KerberosInfo getKerberosInfo(Class<?> protocol, Configuration conf) { if (!protocol .equals(ApplicationHistoryProtocolPB.class)) { return null; } return new KerberosInfo() { @Override public Class<? extends Annotation> annotationType() { return null; } @Override public String serverPrincipal() { return YarnConfiguration.TIMELINE_SERVICE_PRINCIPAL; } @Override public String clientPrincipal() { return null; } }; }
@Override public KerberosInfo getKerberosInfo(Class<?> protocol, Configuration conf) { if (!protocol.equals(ResourceTrackerPB.class)) { return null; } return new KerberosInfo() { @Override public Class<? extends Annotation> annotationType() { return null; } @Override public String serverPrincipal() { return YarnConfiguration.RM_PRINCIPAL; } @Override public String clientPrincipal() { return YarnConfiguration.NM_PRINCIPAL; } }; }
@Override public KerberosInfo getKerberosInfo(Class<?> protocol, Configuration conf) { if (!protocol .equals(HSClientProtocolPB.class)) { return null; } return new KerberosInfo() { @Override public Class<? extends Annotation> annotationType() { return null; } @Override public String serverPrincipal() { return JHAdminConfig.MR_HISTORY_PRINCIPAL; } @Override public String clientPrincipal() { return null; } }; }
@Override public KerberosInfo getKerberosInfo(Class<?> protocol, Configuration conf) { return new KerberosInfo() { @Override public Class<? extends Annotation> annotationType() { return null; } @Override public String serverPrincipal() { return SERVER_PRINCIPAL_KEY; } @Override public String clientPrincipal() { return null; } }; }