org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver.build()方法的使用及代码示例

转载 作者：知者 更新时间：2024-03-13 09:52:00 25 4

/**
 * Called during AM startup to initialize ZK. Checks if any Drillbits are
 * already running. These are "unmanaged" because the AM could not have
 * started them (since they predate the AM.)
 */
public void start(RegistryHandler controller) {
 this.registryHandler = controller;
 try {
  zkDriver.build();
 } catch (ZKRuntimeException e) {
  LOG.error("Failed to start ZK monitoring", e);
  throw new AMWrapperException("Failed to start ZK monitoring", e);
 }
 for (DrillbitEndpoint dbe : zkDriver.getInitialEndpoints()) {
  String key = toKey(dbe);
  registry.put(key, new DrillbitTracker(key, dbe));
  // Blacklist the host for each unmanaged drillbit.
  controller.reserveHost(dbe.getAddress());
  LOG.warn("Host " + dbe.getAddress()
    + " already running a Drillbit outside of YARN.");
 }
 zkDriver.addDrillbitListener(this);
}

/**
 * Basic setup: start a ZK and verify that the initial endpoint list is empty.
 * Also validates the basics of the test setup (mock server, etc.)
 *
 * @throws Exception
 */
@Test
public void testBasics() throws Exception {
 try (TestingServer server = new TestingServer()) {
  server.start();
  String connStr = server.getConnectString();
  ZKClusterCoordinatorDriver driver = new ZKClusterCoordinatorDriver()
    .setConnect(connStr, "drill", "drillbits").build();
  assertTrue(driver.getInitialEndpoints().isEmpty());
  driver.close();
  server.stop();
 }
}

String connStr = server.getConnectString();
ZKClusterCoordinatorDriver driver = new ZKClusterCoordinatorDriver()
  .setConnect(connStr, TEST_ZK_ROOT, TEST_CLUSTER_ID).build();
   .setConnect(connStr, TEST_ZK_ROOT, TEST_CLUSTER_ID).build();
   .setConnect(connStr, TEST_ZK_ROOT, PROBE_CLUSTER_ID).build();
   .setConnect(connStr, PROBE_ZK_ROOT, TEST_CLUSTER_ID).build();
   .setConnect(connStr, TEST_ZK_ROOT, TEST_CLUSTER_ID).build();

.setConnect(connStr, ZK_ROOT, CLUSTER_ID).build();
List<DrillbitEndpoint> bits = driver.getInitialEndpoints();
assertEquals(1, bits.size());

.setPorts(TEST_USER_PORT, TEST_CONTROL_PORT, TEST_DATA_PORT).build();
ZKRegistry registry = new ZKRegistry(driver);
TestRegistryHandler handler = new TestRegistryHandler();

25 4 0

• hadoop-yarn - YARN 中的 yarn-site.xml 与 yarn-default.xml

  YARN 中的 yarn-site.xml 与 yarn-default.xml 有什么区别？看起来yarn-default.xml 在Hadoop 2.2 中已被弃用？ 最佳答案 在所有 Hadoo

• hadoop-yarn - yarn 自动重启失败的应用程序

  我们有一个在 yarn 上运行的流媒体应用程序，我们希望确保它 24/7 全天候运行。 有没有办法告诉 yarn 在失败时自动重启特定的应用程序？ 最佳答案 你试过了吗Hadoop Yarn - Re

• hadoop-yarn - Yarn - yarn.scheduler.capacity.root.queue-name.maximum-capacity 如何工作？

  我在根队列下有 4 个队列，配置如下。 |-------------|-----------------|---------------------|-------------------| | Qu

• hadoop-yarn - 如何杀死 YARN 容器以测试失败场景

  我正在使用 YARN(和 Dask)版本 Hadoop 2.7.3-amzn-1 在 AWS EMR 上构建应用程序。我正在尝试测试各种故障场景，并且我想模拟容器故障。我似乎找不到一种简单的方法来杀死

• hadoop-yarn - 按应用程序名称杀死 yarn 应用程序

  我想创建一个 cron 来通过它的应用程序名称杀死一个 yarn 应用程序(Spark)。但我发现 yarn 应用程序 -kill 需要一个应用程序 ID。是否有解决方案可以通过应用程序名称杀死它，或

• angular - 即使安装了 Yarn 也找不到模块 'yarn'

  我正在尝试从此链接运行通用入门套件:https://github.com/ng-seed/universal即使我按照步骤安装了 Yarn，当我运行命令来运行服务器时，它给了我以下错误: 错误:找不到

• hadoop-yarn - 在 YARN 中托管和非托管应用程序管理器有什么区别

  我正在尝试 YARN 2.2 中的分布式 Shell 示例，希望有人能澄清托管和非托管应用程序管理器之间的区别是什么？ 例如以下几行出现在客户端代码中 // unmanaged AM appConte

• reactjs - yarn 工作区和 yarn 链接

  我有一个像这样的工作区项目: /project - package.json /packages /project-a package.json

• reactjs - yarn 构建和 yarn 安装有什么区别？

  这两个到底做什么用，在哪里使用它们？ yarn 安装 yarn 构建 最佳答案 简而言之，yarn install 是用于安装项目所有依赖项的命令，通常在 package.json 文件中分配。在大多

• javascript - yarn 升级以修复 yarn 审计错误

  所以，到目前为止，似乎没有 yarn audit --fix ，所以我想弄清楚如何修复我的 yarn audit错误。 我试过 yarn upgrade它修复了一些错误(这很好)，但仍然存在一些错误。

• apache-spark - YARN 无法识别增加的 'yarn.scheduler.maximum-allocation-mb' 和 'yarn.nodemanager.resource.memory-mb' 值

  我正在使用一个使用 yarn 的 dockerized pyspark 集群。为了提高数据处理管道的效率，我想增加分配给 pyspark 执行程序和驱动程序的内存量。 这是通过将以下两个键值对添加到

• linux - 我尝试重新安装 yarn ，但重新安装后我发现这个问题，错误 : Cannot find module '/home/fiii/.yarn/releases/yarn-1.22.17.cjs'

  我尝试重新安装yarn，但重新安装后发现这个问题，我尝试搜索互联网但没有找到解决方案。 fiii@neo:~$ yarn --version node:internal/modules/cjs/loa

• yarn-v2 - 初始化 yarn 2，添加失败

  我正在试验2号纱和植面。 我创建了一个新文件夹:/projects/yarn2/根据他们的安装指南https://yarnpkg.com/getting-started我跑了 cd /projects

• hadoop - YARN resourcemanager:带有start-yarn.sh的NoClassDefFoundError

  我是hadoop和YARN的新手。启动hdfs之后，我使用软件包中提供的start-yarn.sh启动YARN并出现错误。 我在Ubuntu 18.04上使用hadoop 3.2.0，jdk-11。

• hadoop-yarn - Spark 中的 yarn 客户端模式是什么？

  Apache Spark最近更新了版本至0.8.1，新增了yarn-client模式。我的问题是，yarn-client 模式的真正含义是什么？在文档中它说: With yarn-client mod

• hadoop - yarn : yarn-site. xml 更改未生效

  我们有一个在 HDFS 2.7.3 上运行的 Spark 流应用程序，使用 Yarn 作为资源管理器....在运行应用程序时......这两个文件夹 /tmp/hadoop/data/nm-local

• javascript - Hadoop YARN 与 Yarn 包管理器命令冲突

  我的机器上的 yarn 命令有问题。我的机器上安装了 hadoop 和 yarn 包管理器(Javascript)。当我运行 yarn init 时，它调用 hadoop 的 YARN 并响应: Er

• java - Hadoop YARN 简单 yarn 应用

  我正在尝试运行此处列出的简单 yarn 应用程序:https://github.com/hortonworks/simple-yarn-app 我是 Java 和 Hadoop 的初学者，当我尝试使用

• hadoop - 指定 YARN 节点标签时 YARN 应用程序无法启动

  我正在尝试使用 YARN node labels标记工作节点，但是当我在 YARN(Spark 或简单的 YARN 应用程序)上运行应用程序时，这些应用程序无法启动。 使用 Spark，指定 --co

• javascript - 如何运行 yarn 应用程序/如何运行 yarn 开发服务器？

  我一直只使用 npm 而从不显式使用 yarn/webpack。我需要从这个 repo 运行代码: https://github.com/looker-open-source/custom_visua