|
@@ -97,7 +97,17 @@ public class TestRMDelegationTokens {
|
|
|
RMDelegationTokenSecretManager dtSecretManager =
|
|
|
rm1.getRMContext().getRMDelegationTokenSecretManager();
|
|
|
// assert all master keys are saved
|
|
|
- Assert.assertEquals(dtSecretManager.getAllMasterKeys(), rmDTMasterKeyState);
|
|
|
+ dtSecretManager.getAllMasterKeys().forEach(managerKey -> {
|
|
|
+ int keyId = managerKey.getKeyId();
|
|
|
+ boolean found = false;
|
|
|
+ for (DelegationKey stateKey: rmDTMasterKeyState) {
|
|
|
+ if (stateKey.getKeyId() == keyId) {
|
|
|
+ found = true;
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ Assert.assertTrue("Master key not found: " + keyId, found);
|
|
|
+ });
|
|
|
|
|
|
// request to generate a RMDelegationToken
|
|
|
GetDelegationTokenRequest request = mock(GetDelegationTokenRequest.class);
|