org.apache.accumulo.fate.zookeeper.ZooLock.deleteLock()方法的使用及代码示例

转载 作者：知者 更新时间：2024-03-13 22:42:03 27 4

@Override
public Repo<Master> call(long tid, Master master) throws Exception {
 // suppress assignment of tablets to the server
 if (force) {
  ZooReaderWriter zoo = master.getContext().getZooReaderWriter();
  String path = master.getZooKeeperRoot() + Constants.ZTSERVERS + "/" + server.getLocation();
  ZooLock.deleteLock(zoo, path);
  path = master.getZooKeeperRoot() + Constants.ZDEADTSERVERS + "/" + server.getLocation();
  zoo.putPersistentData(path, "forced down".getBytes(UTF_8), NodeExistsPolicy.OVERWRITE);
 }
 return null;
}

public static void main(String[] args) throws Exception {
 try (ServerContext context = new ServerContext(new SiteConfiguration())) {
  String tserverPath = context.getZooKeeperRoot() + Constants.ZTSERVERS;
  Opts opts = new Opts();
  opts.parseArgs(TabletServerLocks.class.getName(), args);
  ZooCache cache = context.getZooCache();
  ZooReaderWriter zoo = context.getZooReaderWriter();
  if (opts.list) {
   List<String> tabletServers = zoo.getChildren(tserverPath);
   for (String tabletServer : tabletServers) {
    byte[] lockData = ZooLock.getLockData(cache, tserverPath + "/" + tabletServer, null);
    String holder = null;
    if (lockData != null) {
     holder = new String(lockData, UTF_8);
    }
    System.out.printf("%32s %16s%n", tabletServer, holder);
   }
  } else if (opts.delete != null) {
   ZooLock.deleteLock(zoo, tserverPath + "/" + args[1]);
  } else {
   System.out.println(
     "Usage : " + TabletServerLocks.class.getName() + " -list|-delete <tserver lock>");
  }
 }
}

String path = tserversPath + "/" + child;
if (zoo.getChildren(path).size() > 0) {
 if (!ZooLock.deleteLock(zoo, path, "tserver")) {
  message("Did not delete " + tserversPath + "/" + child, opts);

private void killMacGc() throws ProcessNotFoundException, InterruptedException, KeeperException {
 // kill gc started by MAC
 getCluster().killProcess(ServerType.GARBAGE_COLLECTOR,
   getCluster().getProcesses().get(ServerType.GARBAGE_COLLECTOR).iterator().next());
 // delete lock in zookeeper if there, this will allow next GC to start quickly
 String path = ZooUtil.getRoot(new ZooKeeperInstance(getCluster().getClientConfig()))
   + Constants.ZGC_LOCK;
 ZooReaderWriter zk = new ZooReaderWriter(cluster.getZooKeepers(), 30000, OUR_SECRET);
 try {
  ZooLock.deleteLock(zk, path);
 } catch (IllegalStateException e) {
 }
 assertNull(getCluster().getProcesses().get(ServerType.GARBAGE_COLLECTOR));
}

27 4 0

• sqoop - 警告 :/usr/lib/sqoop/. ./accumulo 不存在! Accumulo 导入将失败。请将 $ACCUMULO_HOME 设置为 Accumulo 安装的根目录

  我的虚拟机详细信息: Cloudera 快速入门 VM 5.5.0 VM = VM 工作站 12 播放器 Windows = Windows 10/64 位 Java = Java 1.8 当我运行“

• hadoop - 如何删除所有 accumulo 表或为 accumulo 格式化 hadoop 文件

  我想为我的本地机器清除 accumulo 中的所有记录，并想删除在测试时创建的未使用的表。我发现可以从 accumulo shell 使用 delete table 命令，但是这将需要大量手动工作来删

• node.js - 如何通过 Accumulo 代理客户端基于 rowkey 删除 Accumulo 中的记录

  我正在使用 Accumulo 1.6，并且希望通过 Nodejs 中的 Accumulo 代理客户端给定的 rowkey 来删除一些记录。 但是当我尝试将相同的行键放入deleteRows API 时

• accumulo - 如何删除累积的实例？

  我在初始化 accumulo 时创建了一个实例，方法是调用 累积初始化 但现在我想删除该实例，并且我想创建一个新实例。 任何人都可以帮助做到这一点吗？ 最佳答案 从 HDFS 中删除 $ACCUMUL

• accumulo - 配置累加器时出现问题

  在我的系统中，Hadoop和Zookeeper正常工作。现在我刚刚配置了Accumulo。但是当我要通过以下方式初始化Accumulo时 累积初始 它显示以下错误。 [root@hydDev32 bi

• installation - Accumulo 卡住无法启动

  我一直在尝试安装 Accumulo 并试用了几天，但它甚至在开始之前就已经备货了。我最终使用了安装了 Hadoop 和 Zookeeper 的 HortonWorks Sandbox。我按照 Accm

• apache - 将数据写入Apache Accumulo

  我想将流数据写入accumulo!。有任何用于累积写入数据的API。可以用python代替java吗？ 最佳答案 通过BatchWriter实例化查看Connector。 Accumulo Thrif

• java - Accumulo - 获取正确排序的扫描仪结果

  有没有办法对扫描仪获得的条目进行排序？我遇到的问题是，我有后缀索引来减少重复的行 ID，并且当我扫描时，我没有得到完美的升序有序列表。例如，我得到如下所示的内容: RowId: 2013-08-05

• java - accumulo 中插入表的行数

  我已将一些行插入到 Accumulo 的表格中。有些行是新创建的，有些行是更新的。 如何找到插入或更新到Java 中的累加表？ def obj= jsonObject["obj"] for(entry

• apache - Accumulo -- 添加一个新节点

  我正在努力学习 Accumulo。但我有几个问题无法直接找到: 首先，我们能否在不停机的情况下向现有的 Accumulo 系统添加新服务器？如果是，则新节点将由 master 安排其共享(DB 数据)

• hadoop - accumulo 无法加载平板电脑

  Accumulo 无法加载、删除或创建新表。我的默认用户是 root。 Master 和 tablet server 和 zookeeper 还活着。 早些时候我试图通过使用 accululo ini

• hadoop - Accumulo 表名称映射问题

  我的 Accumulo 实例已损坏。当我启动我的实例时，它抛出了一个错误，指出我的元数据表已损坏。然后我从 hdfs 的 Accumulo 目录备份了我的数据，并在我的实例上做了一个初始化。我没有意识

• hadoop - Accumulo:没有平板电脑服务器

  ./bin/accumulo shell -u root Password: ****** 2015-02-14 15:18:28,503 [impl.ServerClient] WARN : The

• performance - Accumulo 高速摄取选项

  简而言之，我有一个客户想要将一堆 ASCII 文本文件(又名“输入文件”)中包含的数据摄取到 Accumulo 中。 这些文件是从不同的数据馈送设备输出的，并将在非 Hadoop/非 Accumulo

• hadoop - 如何更改 Accumulo 平板电脑服务器名称以从远程客户端访问？

  我一直在运行一个单节点 Accumulo 应用程序，只要客户端应用程序在同一台机器上运行，它就一直运行良好。现在我需要将客户端迁移到另一台机器，但运行应用程序会给出以下警告，不允许程序继续: WARN

• java - Accumulo 范围 - 不包含结束键

  我正在学习 Accumulo，似乎无法让 Range 中指定的结束键包含在内。我的代码如下。我尝试在 Range 中将 endKeyInclusive 显式设置为 true，但这没有帮助。 Batch

• java - 限制 Accumulo 中的查询量

  请问有没有办法让accumlo限制用户的扫描量？例如，每天只允许其他用户进行 10 次扫描。 最佳答案 Accumulo 有一个可插拔接口(interface) authentication和 tab

• java - 获取 Accumulo 实例名称

  我想使用 GeoMesa(Accumulo 的 GIS 扩展)并使用 Docker 对其进行虚拟化，就像 this repo 一样。现在我想使用 Java 连接到 Accumulo 实例: Inst

• c# - Accumulo createBatchScanner 范围未按预期工作

  我无法让批处理扫描仪只扫描特定行，当设置启动和停止键到相同的东西时我没有返回任何条目，当使用扫描仪时我得到这个异常: "java.lang.IllegalArgumentException: Star

• java - Accumulo - 将突​​变集合添加到超过缓冲区限制的 batchwriter

  当您向总大小超过设置缓冲区的 BatchWriter 添加 Mutations 集合时会发生什么？ BatchWriter 是否只是说好的，我将处理我设置的内容，然后再处理其余的？ 最佳答案 Accu