Examples of AMRMTokenSecretManager

org.apache.hadoop.yarn.server.resourcemanager.security.AMRMTokenSecretManager
AMRM-tokens are per ApplicationAttempt. If users redistribute their tokens, it is their headache, god save them. I mean you are not supposed to distribute keys to your vault, right? Anyways, ResourceManager saves each token locally in memory till application finishes and to a store for restart, so no need to remember master-keys even after rolling them.

Examples of org.apache.hadoop.yarn.server.resourcemanager.security.AMRMTokenSecretManager

    Configuration conf = new YarnConfiguration();
    RMStateStore store = stateStoreHelper.getRMStateStore();
    TestDispatcher dispatcher = new TestDispatcher();
    store.setDispatcher(dispatcher);


    AMRMTokenSecretManager appTokenMgr =
        new AMRMTokenSecretManager(conf);
    ClientToAMTokenSecretManagerInRM clientToAMTokenMgr =
        new ClientToAMTokenSecretManagerInRM();


    ApplicationAttemptId attemptId1 = ConverterUtils
        .toApplicationAttemptId("appattempt_1352994193343_0001_000001");

View Full Code Here

Examples of org.apache.hadoop.yarn.server.resourcemanager.security.AMRMTokenSecretManager

    }
  }


  protected AMRMTokenSecretManager createAMRMTokenSecretManager(
      Configuration conf) {
    return new AMRMTokenSecretManager(conf);
  }

View Full Code Here

Examples of org.apache.hadoop.yarn.server.resourcemanager.security.AMRMTokenSecretManager

        new ContainerAllocationExpirer(nullDispatcher);
    
    Configuration conf = new Configuration();
    RMContext rmContext =
        new RMContextImpl(nullDispatcher, cae, null, null, null,
          new AMRMTokenSecretManager(conf),
          new RMContainerTokenSecretManager(conf),
          new NMTokenSecretManagerInRM(conf),
          new ClientToAMTokenSecretManagerInRM());
    
    return rmContext;

View Full Code Here

Examples of org.apache.hadoop.yarn.server.resourcemanager.security.AMRMTokenSecretManager

    Configuration conf = new YarnConfiguration();
    RMStateStore store = stateStoreHelper.getRMStateStore();
    TestDispatcher dispatcher = new TestDispatcher();
    store.setRMDispatcher(dispatcher);


    AMRMTokenSecretManager appTokenMgr =
        new AMRMTokenSecretManager(conf);
    ClientToAMTokenSecretManagerInRM clientToAMTokenMgr =
        new ClientToAMTokenSecretManagerInRM();


    ApplicationAttemptId attemptId1 = ConverterUtils
        .toApplicationAttemptId("appattempt_1352994193343_0001_000001");

View Full Code Here

Examples of org.apache.hadoop.yarn.server.resourcemanager.security.AMRMTokenSecretManager

        new ContainerAllocationExpirer(nullDispatcher);
    
    Configuration conf = new Configuration();
    RMContext rmContext =
        new RMContextImpl(nullDispatcher, cae, null, null, null,
          new AMRMTokenSecretManager(conf),
          new RMContainerTokenSecretManager(conf),
          new NMTokenSecretManagerInRM(conf),
          new ClientToAMTokenSecretManagerInRM());
    
    return rmContext;

View Full Code Here

Examples of org.apache.hadoop.yarn.server.resourcemanager.security.AMRMTokenSecretManager

    AMLivelinessMonitor amFinishingMonitor = mock(AMLivelinessMonitor.class);
    store = mock(RMStateStore.class);
    this.rmContext =
        new RMContextImpl(rmDispatcher,
          containerAllocationExpirer, amLivelinessMonitor, amFinishingMonitor,
          null, new AMRMTokenSecretManager(conf),
          new RMContainerTokenSecretManager(conf),
          new NMTokenSecretManagerInRM(conf),
          new ClientToAMTokenSecretManagerInRM());
    ((RMContextImpl)rmContext).setStateStore(store);

View Full Code Here

Examples of org.apache.hadoop.yarn.server.resourcemanager.security.AMRMTokenSecretManager

    Configuration conf = new YarnConfiguration();
    RMStateStore store = stateStoreHelper.getRMStateStore();
    TestDispatcher dispatcher = new TestDispatcher();
    store.setRMDispatcher(dispatcher);


    AMRMTokenSecretManager appTokenMgr =
        new AMRMTokenSecretManager(conf);
    ClientToAMTokenSecretManagerInRM clientToAMTokenMgr =
        new ClientToAMTokenSecretManagerInRM();


    ApplicationAttemptId attemptId1 = ConverterUtils
        .toApplicationAttemptId("appattempt_1352994193343_0001_000001");

View Full Code Here

Examples of org.apache.hadoop.yarn.server.resourcemanager.security.AMRMTokenSecretManager

    return new NMTokenSecretManagerInRM(conf);
  }


  protected AMRMTokenSecretManager createAMRMTokenSecretManager(
      Configuration conf) {
    return new AMRMTokenSecretManager(conf);
  }

View Full Code Here

Examples of org.apache.hadoop.yarn.server.resourcemanager.security.AMRMTokenSecretManager

    
    Configuration conf = new Configuration();
    RMApplicationHistoryWriter writer =  mock(RMApplicationHistoryWriter.class);
    RMContext rmContext =
        new RMContextImpl(nullDispatcher, cae, null, null, null,
          new AMRMTokenSecretManager(conf),
          new RMContainerTokenSecretManager(conf),
          new NMTokenSecretManagerInRM(conf),
          new ClientToAMTokenSecretManagerInRM(), writer);
    
    return rmContext;

View Full Code Here

Examples of org.apache.hadoop.yarn.server.resourcemanager.security.AMRMTokenSecretManager

    Configuration conf = new YarnConfiguration();
    RMStateStore store = stateStoreHelper.getRMStateStore();
    TestDispatcher dispatcher = new TestDispatcher();
    store.setRMDispatcher(dispatcher);


    AMRMTokenSecretManager appTokenMgr =
        new AMRMTokenSecretManager(conf);
    ClientToAMTokenSecretManagerInRM clientToAMTokenMgr =
        new ClientToAMTokenSecretManagerInRM();


    ApplicationAttemptId attemptId1 = ConverterUtils
        .toApplicationAttemptId("appattempt_1352994193343_0001_000001");

View Full Code Here

0 1 2

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.