org.apache.hadoop.ha.ZKFCRpcServer类的使用及代码示例

转载 作者：知者 更新时间：2024-03-14 07:05:31 27 4

protected void initRPC() throws IOException {
 InetSocketAddress bindAddr = getRpcAddressToBindTo();
 rpcServer = new ZKFCRpcServer(conf, bindAddr, this, getPolicyProvider());
}

protected void startRPC() throws IOException {
 rpcServer.start();
}

throw e;
} finally {
 rpcServer.stopAndJoin();

@Override
protected void initRPC() throws IOException {
 super.initRPC();
 localNNTarget.setZkfcPort(rpcServer.getAddress().getPort());
}

@Override
protected void initRPC() throws IOException {
 super.initRPC();
 localNNTarget.setZkfcPort(rpcServer.getAddress().getPort());
}

protected void initRPC() throws IOException {
 InetSocketAddress bindAddr = getRpcAddressToBindTo();
 rpcServer = new ZKFCRpcServer(conf, bindAddr, this, getPolicyProvider());
}

protected void startRPC() throws IOException {
 rpcServer.start();
}

mainLoop();
} finally {
 rpcServer.stopAndJoin();

@Override
protected void initRPC() throws IOException {
 super.initRPC();
 localNNTarget.setZkfcPort(rpcServer.getAddress().getPort());
}

protected void initRPC() throws IOException {
 InetSocketAddress bindAddr = getRpcAddressToBindTo();
 rpcServer = new ZKFCRpcServer(conf, bindAddr, this, getPolicyProvider());
}

protected void startRPC() throws IOException {
 rpcServer.start();
}

mainLoop();
} finally {
 rpcServer.stopAndJoin();

protected void initRPC() throws IOException {
 InetSocketAddress bindAddr = getRpcAddressToBindTo();
 rpcServer = new ZKFCRpcServer(conf, bindAddr, this, getPolicyProvider());
}

protected void startRPC() throws IOException {
 rpcServer.start();
}

mainLoop();
} finally {
 rpcServer.stopAndJoin();

protected void initRPC() throws IOException {
 InetSocketAddress bindAddr = getRpcAddressToBindTo();
 rpcServer = new ZKFCRpcServer(conf, bindAddr, this, getPolicyProvider());
}

protected void startRPC() throws IOException {
 rpcServer.start();
}

mainLoop();
} finally {
 rpcServer.stopAndJoin();

27 4 0

• hadoop - 将非 HA Hadoop 集群转换为 HA 集群

  我有一个具有 3 个节点的非 HA Hadoop 设置:一个 NameNode 和 2 个 DataNode。 NameNode是一个4GB内存和20GB硬盘的服务器，而每个DataNode有8GB内

• RabbitMQ ha-promote-on-shutdown 与 ha-promote-on-failure

  关于 https://www.rabbitmq.com/ha.html我读到了这两个属性: ha-promote-on-shutdown ha-promote-on-failure 但是我找不到关于这

• python - 如果 x 是列表，为什么 x += "ha"工作，而 x = x + "ha"抛出异常？

  据我所知，列表的 + op 只要求第二个操作数是可迭代的，“ha”显然是。 在代码中: >>> x = [] >>> x += "ha" >>> x ['h', 'a'] >>> x = x + "h

• 没有集群的Redis HA

  我试图在网上找到更多关于它的信息，但似乎找不到合适的答案。 我们的新应用程序在顶部使用 HA 负载均衡器将访问者分配到集群 ampq 和集群 mysql，一切都完美无缺。 现在我们已经决定我们需要将我

• RabbitMQ HA 和故障转移

  我已经阅读了 clustering和 HA章节并对 RabbitMQ 集群有了一个公平的理解。我不明白的一件事是，集群上有 2 个以上的节点和一组 HA 队列，客户端如何建立连接，以便在一个节点发生故

• hadoop - HBase使用HDFS HA

  我正在尝试使用Hadoop HA设置hbase ha。 我已经设置了Hadoop HA，并对其进行了测试。 但是在HBase安装中，启动时出现以下错误: 2020-05-02 16:11:09,336

• networking - 通过VPN的Neo4j HA？

  我目前正在创建3个Neo4j高可用性服务器。我的业务逻辑将一台服务器作为专用主服务器，而将另外两台计算机作为专用从服务器。我的从服务器与主服务器存在于完全不同的数据中心中。 在两个应用程序之间建立链接

• postgresql - 带有Kubernetes和Gluster的GitLab HA

  我目前在Docker上安装了GitLab omnibus。我计划通过将其添加到Kubernetes来具有相同的HA，并使用Gluster保持持久性。我玩过用Gluster配置Kubernetes的游戏

• docker - 生产中 - HA

  如何使用主动/主动或主动/备用 HA 系统在生产环境中运行 docker？有任何指南或最佳实践吗？ 我正在考虑 3 个场景: 1) NFS - 用于两台服务器 - 准备有 docker-machine

• RabbitMQ HA 镜像同步微调

  我使用rabbitmq-server-3.6.1。 似乎有两个选项如何设置同步批量大小。第一个是策略选项“ha-sync-batch-size”。 RabbitMQ 文档 here 中对此进行了描述。

• linux - HA - 心跳和网络服务器

  *我正在使用 hearbeat 2.1.4 2 个节点正常工作，但是当我在 node1 中手动停止 httpd 时，heartbeat 不会切换到 node02。如何解决这个问题？？* 最佳答案 该版

• Hadoop HA Namenode远程访问

  我正在使用 HA 名称节点配置 Hadoop 2.2.0 稳定版，但我不知道如何配置对集群的远程访问。 我配置了手动故障转移的 HA 名称节点，我定义了 dfs.nameservices，我可以从集群

• docker - 比较我的用例的 HA 集群平台

  我一直在尝试 Docker Swarm 并研究其他解决方案，例如 Kubernetes，但我就是不知道什么最适合我的用例，我可以从专家那里获得一些帮助，所以非常欢迎您的意见. 我对要构建的云有一些要求

• scala - 从Spark作业访问HDFS HA(UnknownHostException错误)

  我有Apache Mesos 0.22.1集群(3个主节点和5个从节点)，在HA配置和Spark 1.5.1框架中运行Cloudera HDFS(2.5.0-cdh5.3.1)。 当我尝试 Spark

• hadoop - Hadoop HA:-使用新名称节点恢复失败的名称节点

  我正在阅读《 Hadoop最终指导》中的“高可用性”，以下内容并不清楚， To recover from a failed namenode in this situation, an adminis

• docker - 使Docker Registry HA

  请注意:这是一个非常相似的问题as this one，但是我断言这不是骗子!另一个问题显然是基于(较旧的)基于Python的Docker注册表，而不是用GoLang编写的最新注册表，而且看起来有很大不

• MySQL 代理 HA，节点故障后无需重新连接

  我使用 MySQL 和 Galera wsrep 来获得同步复制，该部分已启动并运行 我需要设置一种代理来处理客户端连接。由于集群中的任何节点都可能发生故障，因此客户端不会直接连接节点，而只能通过代理

• java - HA Karaf 酒窖群

  我的机器上的一个地窖组中有三个 karaf 节点。第一个节点 (lb_node) 用作负载均衡器，其他两个节点(1_node 和 2_node)用作服务节点(具有已部署的功能)。两个节点都有可用的 /

• c# - 不支持区域性名称 'ha-latn'

  我正在使用 Win-8 机器并尝试创建多语言网站。 我使用的是法语、阿拉伯语和豪萨语。 我的代码运行完美，但是当我选择豪萨语时出现错误: Culture name 'ha-latn' is not s

• hadoop - HDFS HA 可能性

  最近，我成功地为 HDFS 和 YARN 启用了 HA。现在我有一个事件的和备用的名称节点，自动故障转移工作正常。我正在使用 Cloudera Manager 和 CDH 5。 我有以下问题。 例如，