本文整理了Java中org.apache.hadoop.hdfs.web.WebHdfsFileSystem.cancelDelegationToken()方法的一些代码示例，展示了WebHdfsFileSystem.cancelDelegationToken()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。WebHdfsFileSystem.cancelDelegationToken()方法的具体详情如下：
包路径：org.apache.hadoop.hdfs.web.WebHdfsFileSystem
类名称：WebHdfsFileSystem
方法名：cancelDelegationToken

WebHdfsFileSystem.cancelDelegationToken介绍

暂无

代码示例

代码示例来源：origin: org.apache.hadoop/hadoop-hdfs-client

@Override
public synchronized void close() throws IOException {
 try {
  if (canRefreshDelegationToken && delegationToken != null) {
   cancelDelegationToken(delegationToken);
  }
 } catch (IOException ioe) {
  LOG.debug("Token cancel failed: ", ioe);
 } finally {
  super.close();
 }
}

代码示例来源：origin: ch.cern.hadoop/hadoop-hdfs

@Override
public synchronized void close() throws IOException {
 try {
  if (canRefreshDelegationToken && delegationToken != null) {
   cancelDelegationToken(delegationToken);
  }
 } catch (IOException ioe) {
  LOG.debug("Token cancel failed: "+ioe);
 } finally {
  super.close();
 }
}

代码示例来源：origin: io.prestosql.hadoop/hadoop-apache

@Override
public synchronized void close() throws IOException {
 try {
  if (canRefreshDelegationToken && delegationToken != null) {
   cancelDelegationToken(delegationToken);
  }
 } catch (IOException ioe) {
  LOG.debug("Token cancel failed: "+ioe);
 } finally {
  super.close();
 }
}

代码示例来源：origin: ch.cern.hadoop/hadoop-hdfs

Token<?> token = fs.getDelegationToken(null);
fs.renewDelegationToken(token);
fs.cancelDelegationToken(token);
verify(fs, never()).getDelegationToken();
verify(fs, never()).replaceExpiredDelegationToken();
fs.cancelDelegationToken(token);
try {
 fs.renewDelegationToken(token);
 fs.cancelDelegationToken(token);
 Assert.fail("should have failed");
} catch (InvalidToken it) {
fs.cancelDelegationToken(fs.getRenewToken());
is = fs.open(p);
is.read();
verify(fs, never()).getDelegationToken(anyString());
verify(fs, never()).setDelegationToken(any(Token.class));
verify(fs, times(1)).cancelDelegationToken(eq(token2));
fs.cancelDelegationToken(token);
for (int i=0; i<2; i++) {
 try {
verify(fs, never()).getDelegationToken(anyString());
verify(fs, never()).setDelegationToken(any(Token.class));
verify(fs, never()).cancelDelegationToken(any(Token.class));

代码示例来源：origin: ch.cern.hadoop/hadoop-hdfs

@Test
public void testSecureHAToken() throws IOException, InterruptedException {
 Configuration conf = DFSTestUtil.newHAConfiguration(LOGICAL_NAME);
 conf.setBoolean(DFSConfigKeys
     .DFS_NAMENODE_DELEGATION_TOKEN_ALWAYS_USE_KEY, true);
 MiniDFSCluster cluster = null;
 WebHdfsFileSystem fs = null;
 try {
  cluster = new MiniDFSCluster.Builder(conf).nnTopology(topo)
    .numDataNodes(0).build();
  HATestUtil.setFailoverConfigurations(cluster, conf, LOGICAL_NAME);
  cluster.waitActive();
  fs = spy((WebHdfsFileSystem) FileSystem.get(WEBHDFS_URI, conf));
  FileSystemTestHelper.addFileSystemForTesting(WEBHDFS_URI, conf, fs);
  cluster.transitionToActive(0);
  Token<?> token = fs.getDelegationToken(null);
  cluster.shutdownNameNode(0);
  cluster.transitionToActive(1);
  token.renew(conf);
  token.cancel(conf);
  verify(fs).renewDelegationToken(token);
  verify(fs).cancelDelegationToken(token);
 } finally {
  IOUtils.cleanup(null, fs);
  if (cluster != null) {
   cluster.shutdown();
  }
 }
}